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
I am trying to create a dummy wrapper class ( a mongoengine Document ) that implements the interface of Redis hashes. For example:
Under some conditions, I want to make a celery task fail from within that task. I tried the following:
I have to implement a Task subclass that gracefully fails if the broker is not running - currently I\'m using RabbitMQ.
I need to run some tasks on the specific celeryd instance. So I configured queues: celeryconfig.py: CELERY_QUEUES = {
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
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.
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.
I am using python celery+rabbitmq. I can\'t find a way to get task count in some queue. Some thing like this:
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
加载中,请稍侯......