celery.worker.consumer

Worker consumer.

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

Agent starts cell actors.

conditional = True
create(c)[исходный код]

Create the step.

name = 'celery.worker.consumer.agent.Agent'
requires = (step:celery.worker.consumer.connection.Connection{()},)
class celery.worker.consumer.Connection(c, **kwargs)[исходный код]

Service managing the consumer broker connection.

info(c)[исходный код]
name = 'celery.worker.consumer.connection.Connection'
shutdown(c)[исходный код]
start(c)[исходный код]
class celery.worker.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.Control(c, **kwargs)[исходный код]

Remote control command service.

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

Return true if bootstep should be included.

You can define this as an optional predicate that decides whether this step should be created.

name = 'celery.worker.consumer.control.Control'
requires = (step:celery.worker.consumer.tasks.Tasks{(step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)},)
class celery.worker.consumer.Events(c, task_events=True, without_heartbeat=False, without_gossip=False, **kwargs)[исходный код]

Service used for sending monitoring events.

name = 'celery.worker.consumer.events.Events'
requires = (step:celery.worker.consumer.connection.Connection{()},)
shutdown(c)[исходный код]
start(c)[исходный код]
stop(c)[исходный код]
class celery.worker.consumer.Gossip(c, without_gossip=False, interval=5.0, heartbeat_interval=2.0, **kwargs)[исходный код]

Bootstep consuming events from other workers.

This keeps the logical clock value up to date.

call_task(task)[исходный код]
compatible_transport(app)[исходный код]
compatible_transports = {'amqp', 'redis'}
election(id, topic, action=None)[исходный код]
get_consumers(channel)[исходный код]
label = 'Gossip'
name = 'celery.worker.consumer.gossip.Gossip'
on_elect(event)[исходный код]
on_elect_ack(event)[исходный код]
on_message(prepare, message)[исходный код]
on_node_join(worker)[исходный код]
on_node_leave(worker)[исходный код]
on_node_lost(worker)[исходный код]
periodic()[исходный код]
register_timer()[исходный код]
requires = (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)
start(c)[исходный код]
class celery.worker.consumer.Heart(c, without_heartbeat=False, heartbeat_interval=None, **kwargs)[исходный код]

Bootstep sending event heartbeats.

This service sends a worker-heartbeat message every n seconds.

Примечание

Not to be confused with AMQP protocol level heartbeats.

name = 'celery.worker.consumer.heart.Heart'
requires = (step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)
shutdown(c)
start(c)[исходный код]
stop(c)[исходный код]
class celery.worker.consumer.Mingle(c, without_mingle=False, **kwargs)[исходный код]

Bootstep syncing state with neighbor workers.

At startup, or upon consumer restart, this will:

  • Sync logical clocks.

  • Sync revoked tasks.

compatible_transport(app)[исходный код]
compatible_transports = {'amqp', 'redis'}
label = 'Mingle'
name = 'celery.worker.consumer.mingle.Mingle'
on_clock_event(c, clock)[исходный код]
on_node_reply(c, nodename, reply)[исходный код]
on_revoked_received(c, revoked)[исходный код]
requires = (step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)
send_hello(c)[исходный код]
start(c)[исходный код]
sync(c)[исходный код]
sync_with_node(c, clock=None, revoked=None, **kwargs)[исходный код]
class celery.worker.consumer.Tasks(c, **kwargs)[исходный код]

Bootstep starting the task message consumer.

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

Return task consumer info.

name = 'celery.worker.consumer.tasks.Tasks'
requires = (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)
shutdown(c)[исходный код]

Shutdown task consumer.

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

Start task consumer.

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

Stop task consumer.

Вернуться на верх