3回答
我用的是姜戈芹菜和芹菜，不工作 => celeryDatabaseScheduler
Works => celery worker --app=my_project.
浏览 7提问于2020-08-11得票数 0
1回答
我使用气流版本2.2.2和芹菜作为执行器。这就是我想要达到的目标以前我用芹菜和芹菜解决了这个案子。由于将应用程序移动到基于集群的调度程序，我们正在尝试使用气流。有人能建议我们在这个用例中使用气流吗？
浏览 3提问于2021-12-02得票数 1
我有大约一百万的气流任务，使用相同的python功能。每个运行都需要有不同的开始日期和参数。问题
如何在气流上以可伸缩的方式运行一百万(或任何数量)或任务，其中每个任务来自同一个python函数，但有不同的开始日期和不同的参数？不管怎样，DAG贡献背后的架构问题仍
浏览 0提问于2019-03-25得票数 1
回答已采纳
1回答
我有一个ETL管道，它由以下任务组成：
我把整个剧本转换成气流数据集。我的问题是假设，一个百万文件的规模，我想特别是在步骤-3使用我的整个集群芹菜工人处理文件并行。例如，假设我有100个芹菜工作节点，每个节点有两个核
浏览 2提问于2019-04-24得票数 4
回答已采纳
1回答
我正在吃芹菜，我不明白的是芹菜和芹菜节拍。假设我的系统每秒发送数百条消息。我应该用芹菜还是芹菜。
我应该在哪里使用芹菜和芹菜节拍。芹菜和芹菜有什么区别？
浏览 1提问于2015-06-10得票数 1
，这是我想要实现的流程。
目前，我正在尝试使用Thread和Queue类来实现这一点。我想知道的是，在没有这么多线程的情况下，我如何管理这个流？
浏览 0提问于2018-04-01得票数 0
回答已采纳
我有一个代码库，每个应用程序都有tasks.py，总共有100个这样的函数def sync_calendar_availability_and_prices(listing_id_list=None, reapply_rules_after_sync=False):
它采用的是旧格式的芹菜周期性任务定义，但在celery==4.1上运行良好。它们每隔几个小时或几分钟通过节拍
浏览 0提问于2018-10-28得票数 0
新的气流，所以道歉，如果这个问题没有真正的意义。在webserver中是否有一个命令或位置可以看到所有正在运行的工作人员的列表？另外，如果没有使用airflow worker显式启动芹菜工作节点，是否存在使用not服务器或调度程序初始化的“默认”工作人员？
浏览 1提问于2020-11-17得票数 2
回答已采纳
我正在从事一个Dockerized /Django项目，其中包括一个用于芹菜工人的容器，我一直在将现成的气流码头容器集成到其中。我已经在预先存在的容器中成功地运行了芹菜任务，方法是使用指定的redis代理和后端实例化芹菜应用程序，并通过send_task进行远程调用；然而，芹菜任务执行的日志记录都不能返回到气流日志。最初，作为一个概念的证明，因为我对<e
浏览 6提问于2022-06-08得票数 1
1回答
芹菜任务没有注册吗？
、、、、
我使用Django +芹菜动态调度任务。调度任务的时间将从用户数据库中查询或由用户动态提供。我试图将一个参数传递给start_task函数，但是它破坏了代码，因为调度程序无法将它添加到它的条目中。
浏览 3提问于2021-01-21得票数 0
回答已采纳
2回答
我已经设置了一个芹菜任务，它使用RabbitMQ作为代理，使用Redis作为后端。运行之后，我注意到我的Redis服务器仍在使用大量内存。经过检查，我发现创建的每个任务仍然有密钥。只有在收到回复后，才有办法让芹菜清理这些钥匙吗？我知道有些MessageBrokers用的是ack，在芹菜中有相当于红色后端的东西吗？
浏览 3提问于2017-11-08得票数 0
回答已采纳
我正在尝试从tornado应用程序界面启动和停止芹菜周期性任务。我浏览了很多关于这个话题的stackoverflow问题，但他们都没有回答这个简单的问题。到目前为止，我的tornado应用程序处理简单的</em
浏览 51提问于2019-08-10得票数 0
回答已采纳
因此，我正在运行安装在EC2实例上的超集。在我的config.py文件中，我只做了以下更改： FEATURE_FLAGS = {}
SMTP_HOSTopr:eq,value:Alert)),order_column:name,order_direction:desc,page:0,page_size:25) HTTP/1.1" 200 - 这是UI的截图
浏览 66提问于2021-04-02得票数 0
1回答
我有一个模型，它可以获取事件应该始终发生的日期和时间。此外，活动前的天数，人们将能够参加。 def validate_only_one(obj): else:
# another thing, ie, hidden formulary
浏览 15提问于2019-12-27得票数 0
回答已采纳
2回答
重启芹菜会导致重复的任务吗？
、、、、
我在芹菜中有一个电子邮件任务，从现在起有10天的预计到达时间()。然而，我发现有些人一次会收到5-6封重复的电子邮件。我以前在BROKER_TRANSPORT_OPTIONS设置得太低的情况下遇到过这个问题。现在，我的设置文件中有以下内容：所以这应该不再是问题了。即重新启动芹菜。每次我部署新代码时，Celery都会
浏览 3提问于2016-03-09得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
