我们正在使用 Celery 的任务来处理一些定义需要完成的工作的消息。由于这些 Task 对象是由 Celery 生成的而不是手动生成的，因此 Celery 对消息传递施加了限制，其中发送的信号只能是在应用程序上定义的信号。
目前，计划是在 Celery 将创建的 Task 进程中运行一个 AMQP 消费者线程，该线程将负责设置标志/存储值/每次将特制消息发送到特定信号队列时。
Celery 是否有一个特定功能可以发送此类信号而不会入侵无关和独立的消费者？我们的环境中没有 Django。
我们正在使用 Celery 的任务来处理一些定义需要完成的工作的消息。由于这些 Task 对象是由 Celery 生成的而不是手动生成的，因此 Celery 对消息传递施加了限制，其中发送的信号只能是在应用程序上定义的信号。
目前，计划是在 Celery 将创建的 Task 进程中运行一个 AMQP 消费者线程，该线程将负责设置标志/存储值/每次将特制消息发送到特定信号队列时。
Celery 是否有一个特定功能可以发送此类信号而不会入侵无关和独立的消费者？我们的环境中没有 Django。