【问题标题】:Can't set airflow's celery_result_backend setting to 'rpc://'无法将气流的 celery_result_backend 设置设置为“rpc://”
【发布时间】:2018-03-26 13:29:32
【问题描述】:

“rpc://”是气流配置中“celery_result_backend”设置的有效值吗?它似乎不起作用。

假设它有效,因为它是核心 celery 配置中的有效值。

【问题讨论】:

  • Celery 支持多种broker;你用的是哪一种?后端需要与代理配对。

标签: python celery airflow


【解决方案1】:

由于我们在 Redis 上使用 Celery,因此 URL 都以:redis:// 开头。

如果您将 Celery 与 RabbitMQ 一起使用,则 URL 将以:amqp://

开头

AWS SQS 的开头为:sqs://

我在broker documentation 中看不到任何以rpc:// 开头的队列代理网址。

我确实看到 RabbitMQ 的结果后端可以以 rpc:// 开头,因为它只是传递给相关库的字符串,您是否使用 celery[librabbitmq] 进行了安装,并且您没有像我几乎所做的那样混淆两者?

猜你喜欢
  • 2012-05-26
  • 2023-03-06
  • 1970-01-01
  • 2021-05-03
  • 1970-01-01
  • 2020-05-28
  • 1970-01-01
  • 2021-04-23
  • 1970-01-01
相关资源
最近更新 更多