Difference between revisions of "Celery"

From wikieduonline
Jump to navigation Jump to search
Tags: Mobile web edit, Mobile edit
 
(40 intermediate revisions by 2 users not shown)
Line 1: Line 1:
 
[[wikipedia:celery (software)]] is an open source [[asynchronous task queue]] or job queue which is based on distributed message passing.
 
[[wikipedia:celery (software)]] is an open source [[asynchronous task queue]] or job queue which is based on distributed message passing.
 +
 +
* Installation: <code>[[pip3 install celery]]</code>
 +
* Supported backend and [[Broker]]s: [[RabbitMQ]], [[Redis]], [[Zookeeper]], [[Amazon SQS]], [[SQLAlchemy]]
  
  
<pre>
+
== Commands ==
celery
+
* <code>[[celery --help]]</code>
usage: celery <command> [options]
+
* <code>[[celery list]]</code>
 
+
* <code>[[celery status]]</code>
Show help screen and exit.
+
* <code>[[celery control]]</code>
 
+
* <code>[[celery shell]]</code>
positional arguments:
+
* <code>[[celery worker]]</code>
  args
+
* <code>[[celery -A]]</code>
 
 
optional arguments:
 
  -h, --help            show this help message and exit
 
  --version            show program's version number and exit
 
 
 
Global Options:
 
  -A APP, --app APP
 
  -b BROKER, --broker BROKER
 
  --result-backend RESULT_BACKEND
 
  --loader LOADER
 
  --config CONFIG
 
  --workdir WORKDIR
 
  --no-color, -C
 
  --quiet, -q
 
 
 
---- -- - - ---- Commands- -------------- --- ------------
 
 
 
+ Main:
 
|    celery worker
 
|    celery events
 
|    celery beat
 
|    celery shell
 
|    celery multi
 
|    celery amqp
 
 
 
+ Remote Control:
 
|    celery status
 
 
 
|    celery inspect --help
 
|    celery inspect active
 
|    celery inspect active_queues
 
|    celery inspect clock
 
|    celery inspect conf [include_defaults=False]
 
|    celery inspect memdump [n_samples=10]
 
|    celery inspect memsample
 
|    celery inspect objgraph [object_type=Request] [num=200 [max_depth=10]]
 
|    celery inspect ping
 
|    celery inspect query_task [id1 [id2 [... [idN]]]]
 
|    celery inspect registered [attr1 [attr2 [... [attrN]]]]
 
|    celery inspect report
 
|    celery inspect reserved
 
|    celery inspect revoked
 
|    celery inspect scheduled
 
|    celery inspect stats
 
 
 
|    celery control --help
 
|    celery control add_consumer <queue> [exchange [type [routing_key]]]
 
|    celery control autoscale [max [min]]
 
|    celery control cancel_consumer <queue>
 
|    celery control disable_events
 
|    celery control election
 
|    celery control enable_events
 
|    celery control heartbeat
 
|    celery control pool_grow [N=1]
 
|    celery control pool_restart
 
|    celery control pool_shrink [N=1]
 
|    celery control rate_limit <task_name> <rate_limit (e.g., 5/s | 5/m | 5/h)>
 
|    celery control revoke [id1 [id2 [... [idN]]]]
 
|    celery control shutdown
 
|    celery control terminate <signal> [id1 [id2 [... [idN]]]]
 
|    celery control time_limit <task_name> <soft_secs> [hard_secs]
 
 
 
+ Utils:
 
|    celery purge
 
|    celery list
 
|    celery call
 
|    celery result
 
|    celery migrate
 
|    celery graph
 
|    celery upgrade
 
 
 
+ Debugging:
 
|    celery report
 
|    celery logtool
 
---- -- - - --------- -- - -------------- --- ------------
 
 
 
Type 'celery <command> --help' for help using a specific command.
 
</pre>
 
 
 
  
 
== Related terms ==
 
== Related terms ==
* [[RabbitMQ]]
 
 
* [[Flower]] - Celery monitoring tool<ref>https://flower.readthedocs.io/en/latest/#flower-celery-monitoring-tool</ref>
 
* [[Flower]] - Celery monitoring tool<ref>https://flower.readthedocs.io/en/latest/#flower-celery-monitoring-tool</ref>
 
* <code>django-celery</code> provides Celery integration for [[Django]]
 
* <code>django-celery</code> provides Celery integration for [[Django]]
 +
* <code>[[WorkerLostError: Worker exited prematurely: signal 9 (SIGKILL)]]</code>
 +
* [[Apache Airflow]], [[Apache Airflow providers]]: https://airflow.apache.org/docs/apache-airflow/stable/executor/celery.html
 +
* [[Celery Director]]
 +
* [[Kombu]]
 +
* [[Jobs]]
 +
* <code>[[airflow celery]]</code>
 +
* [[Celery Executor]]
 +
* [[Celery Broker]]
  
 
== See also ==
 
== See also ==
* {{Python}}
+
* {{Celery}}
 
+
* {{Django}}
  
 
[[Category:Python]]
 
[[Category:Python]]
 +
[[Category:Celery]]

Latest revision as of 15:37, 19 January 2023

Advertising: