celery
How to structure my application for several tasks using redis with gevent or threading in Python
I hav开发者_Python百科e a process which sends financial tick data through redis pubsub in realtime. Now I want my Python Application to handle the input data (json) for instance calculations like movi[详细]
2023-04-12 22:36 分类:问答Mongoengine document consistency under concurrency
I am trying to create a dummy wrapper class ( a mongoengine Document ) that implements the interface of Redis hashes. For example:[详细]
2023-04-12 10:06 分类:问答How to make a celery task fail from within the task?
Under some conditions, I want to make a celery task fail from within that task. I tried the following:[详细]
2023-04-11 17:10 分类:问答Celery: abort task on connection error
I have to implement a Task subclass that gracefully fails if the broker is not running - currently I\'m using RabbitMQ.[详细]
2023-04-11 08:00 分类:问答Celery and routing
I need to run some tasks on the specific celeryd instance. So I configured queues: celeryconfig.py: CELERY_QUEUES = {[详细]
2023-04-10 15:14 分类:问答fetching data from celery's backend(redis)
How do I get data开发者_运维技巧(all I really need is the state of the task) from a Celery backend? I am using Redis.Assuming that you configured the CELERY_RESULT_BACKEND to use redis ( see here ), t[详细]
2023-04-09 18:49 分类:问答pymongo error operation failure
I\'m currently using celery with django, i have pymongo ver 1.11 mongodb ver 1.8 I\'m getting following error, i\'m not able to figure out what is the error.[详细]
2023-04-07 13:50 分类:问答How is rate_limit enforced in Celery?
I\'m running a Django website where I use Celery to implement preventive caching - that is, I calculate and cache results even before they are requested by the user.[详细]
2023-04-07 13:43 分类:问答celery get tasks count
I am using python celery+rabbitmq. I can\'t find a way to get task count in some queue. Some thing like this:[详细]
2023-04-07 06:19 分类:问答Wait for the result of an external webservice inside a task
I need to write a bunch of tasks where every task needs to query an external web service. The web service always replies with a 202 ACCEPTED status and points in the Location header to the URI where t[详细]
2023-04-06 21:35 分类:问答