« first day (2906 days earlier)      last day (435 days later) » 

11:27 AM
from kombu import Queue
from celery import Celery

celery = Celery('tasks', broker="redis://localhost:6379/0", backend="rpc://")

celery.conf.update(CELERY_ROUTES=
{
"celery_worker.celery_worker.add": "add",
"celery_worker.celery_worker.read": "read"})

@celery.task(name='add',acks_late=True,reply_to="read")
def add(x, y):
celery_log.info(f"Order Complete!{x}, {y}")
return x + y

@celery.task(name='read',acks_late=True,queue="read")
def read(data):
celery_log.info(f"Order Complete!{data}")
return data
 
1 message moved from Python
 
0
Q: Celery Redis reply to getting "Received and deleted unknown message. Wrong destination?!?"

Geetha SJIam working with Celery Worker with Redis as broker and in backend. Steps: Add process will pick the data from queue and process and the result will be send to read queue. Read process will read the data from read queue and print the result. Before picking up by second task, the message is gett...

added in off-site and for your reference plz
 
11:44 AM
2 messages moved from Python
 

« first day (2906 days earlier)      last day (435 days later) »