在芹菜(Celery)中,可以通过以下步骤获取监听某个队列(Queue)的主机列表:
BROKER_URL = 'amqp://guest:guest@localhost:5672//'
from celery import Celery
app = Celery('myapp', broker='amqp://guest:guest@localhost:5672//')
@app.task
def my_task():
# 任务逻辑代码
pass
celery inspect active_queues
可以获取当前活跃的队列信息,包括队列所在的主机。可以在终端中执行以下命令获取主机列表:celery inspect active_queues
以上命令将返回一个 JSON 格式的结果,其中包含了所有活跃队列的信息,包括队列名称、队列所在的主机等。
Tencent Kubernetes Engine (TKE)
请注意,以上答案仅供参考,具体实现方式可能因环境和需求而异。
云+社区沙龙online第5期[架构演进]
云+社区技术沙龙[第10期]
Elastic 实战工作坊
Elastic 实战工作坊
腾讯技术创作特训营第二季
云+社区技术沙龙[第20期]
云+社区技术沙龙[第6期]
Elastic 中国开发者大会
腾讯位置服务技术沙龙
领取专属 10元无门槛券
手把手带您无忧上云