Celery v5.0.1 Documentation
topic of task granularity [AOC1]. Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*', {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 2313 页 | 2.13 MB | 1 年前3Celery 3.0 Documentation
task granularity [AOC1]. [AOC1] Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*': {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 2110 页 | 2.23 MB | 1 年前3Celery v4.0.0 Documentation
task granularity [AOC1]. [AOC1] Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*': {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 2106 页 | 2.23 MB | 1 年前3Celery v5.0.2 Documentation
topic of task granularity [AOC1]. Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*', {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 2313 页 | 2.14 MB | 1 年前3Celery v5.0.0 Documentation
topic of task granularity [AOC1]. Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*', {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 2309 页 | 2.13 MB | 1 年前3Celery v5.0.5 Documentation
topic of task granularity [AOC1]. Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*', {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 2315 页 | 2.14 MB | 1 年前3Celery 2.0 Documentation
"binding_key": "default"}, "videos": { "exchange": "media", "binding_key": "media.video", }, "images": { "exchange": "media", "binding_key": "media.image", } } CELERY_DEFAULT_QUEUE = "default" CELERY "videos": { "exchange": "media", "exchange_type": "topic", "binding_key": "media.video", }, "images": { "exchange": "media", "exchange_type": "topic", "binding_key": "media.image", } } CELERY_DEFAULT_QUEUE "default", "mytasks.add": "cpu-bound", "video.encode": { "queue": "video", "exchange": "media" "routing_key": "media.video.encode"}} >>> CELERY_ROUTES = ("myapp.tasks.Router", {"celery.ping": "default})0 码力 | 165 页 | 492.43 KB | 1 年前3Celery 2.0 Documentation
"default"}, "videos": { "exchange": "media", "binding_key": "media.video", }, "images": { "exchange": "media", "binding_key": "media.image", } } CELERY_DEFAULT_QUEUE = "exchange": "media", "exchange_type": "topic", "binding_key": "media.video", }, "images": { "exchange": "media", "exchange_type": "topic", "binding_key": "media.image" "queue": "video", "exchange": "media" "routing_key": "media.video.encode"}} >>> CELERY_ROUTES = ("myapp.tasks.Router",0 码力 | 284 页 | 332.71 KB | 1 年前3Celery 3.0 Documentation
add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 100 Chapter 2. Contents 'feeds'}), ('web.tasks.*': {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note: The task_routes setting can either be a dictionary, or a list of router objects, so Exchange('default'), routing_key='default'), Queue('videos', Exchange('media'), routing_key='media.video'), Queue('images', Exchange('media'), routing_key='media.image'), ) app.conf.task_default_queue = 'default' app0 码力 | 703 页 | 2.60 MB | 1 年前3Celery v4.0.1 Documentation
task granularity [AOC1]. [AOC1] Breshears, Clay. Section 2.2.1, “The Art of Concurrency”. O’Reilly Media, Inc. May 15, 2009. ISBN-13 978-0-596-52153-0. Data locality The worker processing the task should add_consumer( ... queue='baz', ... exchange='ex', ... exchange_type='topic', ... routing_key='media.*', ... options={ ... 'queue_durable': False, ... 'exchange_durable': False, 'feeds'}), ('web.tasks.*': {'queue': 'web'}), (re.compile(r'(video|image)\.tasks\..*'), {'queue': 'media'}), ],) Note The task_routes setting can either be a dictionary, or a list of router objects, so0 码力 | 1040 页 | 1.37 MB | 1 年前3
共 51 条
- 1
- 2
- 3
- 4
- 5
- 6