celery.worker.consumer.consumer¶

Worker Consumer Blueprint.

This module contains the components responsible for consuming messages from the broker, processing the messages and keeping the broker connections up and running.

class celery.worker.consumer.consumer.Consumer(on_task_request, init_callback=<function noop>, hostname=None, pool=None, app=None, timer=None, controller=None, hub=None, amqheartbeat=None, worker_options=None, disable_rate_limits=False, initial_prefetch_count=2, prefetch_multiplier=1, **kwargs)[исходный код]¶

Consumer blueprint.

class Blueprint(steps=None, name=None, on_start=None, on_close=None, on_stopped=None)[исходный код]¶

Consumer blueprint.

default_steps = ['celery.worker.consumer.connection:Connection', 'celery.worker.consumer.mingle:Mingle', 'celery.worker.consumer.events:Events', 'celery.worker.consumer.gossip:Gossip', 'celery.worker.consumer.heart:Heart', 'celery.worker.consumer.control:Control', 'celery.worker.consumer.tasks:Tasks', 'celery.worker.consumer.consumer:Evloop', 'celery.worker.consumer.agent:Agent']¶

name = 'Consumer'¶

shutdown(parent)[исходный код]¶

Strategies¶

alias of dict

add_task_queue(queue, exchange=None, exchange_type=None, routing_key=None, **options)[исходный код]¶

apply_eta_task(task)[исходный код]¶

Method called by the timer to apply a task with an ETA/countdown.

bucket_for_task(type)[исходный код]¶

call_soon(p, *args, **kwargs)[исходный код]¶

cancel_task_queue(queue)[исходный код]¶

connect()[исходный код]¶

Establish the broker connection used for consuming tasks.

Retries establishing the connection if the broker_connection_retry setting is enabled

connection_for_read(heartbeat=None)[исходный код]¶

connection_for_write(heartbeat=None)[исходный код]¶

create_task_handler(promise=<class 'vine.promises.promise'>)[исходный код]¶

ensure_connected(conn)[исходный код]¶

init_callback = None¶

Optional callback called the first time the worker is ready to receive tasks.

loop_args()[исходный код]¶

property max_prefetch_count¶

on_close()[исходный код]¶

on_connection_error_after_connected(exc)[исходный код]¶

on_connection_error_before_connected(exc)[исходный код]¶

on_decode_error(message, exc)[исходный код]¶

Callback called if an error occurs while decoding a message.

Simply logs the error and acknowledges the message so it doesn’t enter a loop.

Параметры:

• message (kombu.Message) – The message received.

• exc (Exception) – The exception being handled.

on_invalid_task(body, message, exc)[исходный код]¶

on_ready()[исходный код]¶

on_send_event_buffered()[исходный код]¶

on_unknown_message(body, message)[исходный код]¶

on_unknown_task(body, message, exc)[исходный код]¶

perform_pending_operations()[исходный код]¶

pool = None¶

The current worker pool instance.

register_with_event_loop(hub)[исходный код]¶

reset_rate_limits()[исходный код]¶

restart_count = -1¶

shutdown()[исходный код]¶

start()[исходный код]¶

stop()[исходный код]¶

timer = None¶

A timer used for high-priority internal tasks, such as sending heartbeats.

update_strategies()[исходный код]¶

class celery.worker.consumer.consumer.Evloop(parent, **kwargs)[исходный код]¶

Event loop service.

Примечание

This is always started last.

label = 'event loop'¶

last = True¶

name = 'celery.worker.consumer.consumer.Evloop'¶

patch_all(c)[исходный код]¶

start(c)[исходный код]¶

celery.worker.consumer.consumer.dump_body(m, body)[исходный код]¶

Format message body for debugging purposes.