由于Celery文档建议使用flower进行监控,我正在尝试让它与托管的RabbitMQ提供商(CloudAMQP)一起工作
celery flower --broker=amqp://username:password@lemur.cloudamqp.com/vhost --broker_api=https://lemur.cloudamqp.com/api/ --basic_auth=username:password
我可以在CloudAMQP管理控制台中看到一个500内部服务器错误,如下所示,这似乎表明密码错误,而我没有密码错误。
The server encountered an error while processing this request:
{error,function_clause,
[{rabbit_auth_backend_internal,check_password,
[<<"password">>,
<<>>]},
{rabbit_auth_backend_internal,internal_check_user_login,2},
{rabbit_access_control,'-check_user_login/2-fun-0-',4},
{lists,foldl,3},
{rabbit_mgmt_util,is_authorized,4},
{webmachine_resource,resource_call,3},
{webmachine_resource,do,3},
{webmachine_decision_core,resource_call,1}]}
那么,如何使用cloudamqp监测芹菜呢?
对此,有没有更好的解决方案(监控/任务队列)?
设置broker和broker_api命令行参数。--broker_api标志应该是RabbitMQ HTTP api的URL,broker api端口应该是443。
--broker_api=https://username:password@hostname:443/api/vhost
--broker=amqp://username:password@hostname:5671/vhost?ssl=true