1回答
我试图从竹子中触发气流，并试图让它在前台运行，这样竹子就可以知道触发器的执行何时完成。 有人能建议我如何让竹子在远程服务器上等待气流触发器的执行吗？
浏览 15提问于2020-05-04得票数 1
我想用气流DAG来处理一些工作。我已经安排了每25分钟表达一次，比如*/25 * * * *。例如，它似乎运行在6:25，6:50和7，但我想在7:15运行，而不是在7:15运行。作为另一种选择，我想知道，如果我手动触发DAG，下一个触发器是否会受到此影响，就像下一个触发器会被延迟一样，还是会按自己的计划继续进行。
我使用的气流版本是1.10.4。
浏览 1提问于2019-10-20得票数 4
回答已采纳
1回答
我正在尝试在一个Ubuntu EC2实例中使用docker-compose来设置airflow实例。在气流初始化之后，该过程不再前进。我正在努力修复它。当我尝试在我的windows桌面上运行相同的docker编写文件时，它工作得很好。我不明白为什么它不能在我的EC2实例上工作。
浏览 47提问于2021-08-09得票数 0
3回答
气流中的 -是一种特定类型的操作员，它会一直运行直到达到某一标准，但它们消耗的是一个完整的工人槽。好奇的是，人们是否能够可靠地使用更有效的方法来实现这一点。我脑子里有几个想法
其他相关链接：
浏览 1提问于2018-02-09得票数 7
在气流数据采集系统中，我试图使用一个TimeDeltaTrigger：...但是，当我的DAG运行时，我会在GUI中得到一个警告：在GUI中，如果我去浏览->触发器，我会看到一个触发器</
浏览 1提问于2021-11-10得票数 3
回答已采纳
Airflow webserver仍在前台运行，命令为"airflow webserver -D“。我不确定我是不是漏掉了什么？尽管，气流调度器-D工作正常
浏览 16提问于2019-02-18得票数 0
在的帮助下，我刚刚编写了一个程序(如文章中所示)，当一个文件放置在S3桶中时，会触发运行中的一个DAG中的任务，然后使用BashOperator执行一些工作。我想要使这个程序，使它始终运行和任何时候，一个新的文件被放置在S3桶中，程序开始任务。
我是否可以继续使用S3KeySenor来完成这个任务，或者是否需要找到一种方法来设置一个来运行我的DAG？到目前为止，如果我的S3KeySensor只运行一次的话，它是毫无意义的。t2.set_upstream
浏览 1提问于2018-05-29得票数 25
回答已采纳
1回答
我对气流很陌生，尝试通过启动气流网络服务器和调度程序来运行一个dag。当我关闭调度程序和气流网络服务器后，气流进程仍在运行。ps aux | grep airflow显示了两个气流and服务器运行，以及调度程序运行的所有dags。我试着运行kill $(ps aux | grep airflow | awk '{print $2}')，但是没有帮助。
我没有sudo权限和webserver访问权限
浏览 4提问于2021-01-10得票数 5
回答已采纳
1回答
我最近把我的气流升级到2.2.4。现在，从我的管理控制台，当我点击触发器DAG，它进入排队。它不是立即运行，而是在7个小时后运行。气流调度器和服务器位于PDT时区(比UTC晚7小时)，那么为什么它会触发DAG 'now‘as UTC 'now’而不是set PDT时区？
浏览 7提问于2022-04-22得票数 0
除one_done触发器外，气流还提供多个触发规则。假设我有以下任务依赖项，任务F需要在任何任务( B或C或D或E<code>E 219</>)完成时立即触发，而不管<
浏览 2提问于2022-08-26得票数 1
回答已采纳
1回答
我们目前有一堆独立的作业运行在不同的服务器上&正在使用crontab进行调度。我们的目标是有一个跨服务器的所有作业的单一视图，以及它们是否成功运行等等。气流是我们正在考虑使用的工具之一，以实现这一点。但是我们的服务器配置非常不同。是否可以设置气流，以便DAG1 (以及气流调度器& webserver)在server1上运行，DAG2在没有RabbitMQ的server2上运行。本质上，我想实现类似于这里给出的第一个答案
浏览 1提问于2022-01-14得票数 0
我试图让两个Nexus设备双向交换Ndef消息，而不必为每个单独的消息点击电话。我不认为启用两种设备的前景推送和调度都是一个好主意，因为这种行为可能是不可预测的。我想有一种方法就是让发起人类似于响应者。
唯一的问题是，当前的API似乎不支持步骤4，即在消息成功推送时得到通知。有人能建议怎么做吗？或者有其他的方法来实现单点P
浏览 1提问于2011-04-20得票数 0
我有一个Apache气流管理环境，其中定义并启用了许多DAG。一些DAG是按15分钟的计划运行的，而另一些则没有计划。所有的DAG都是单任务DAG。DAG的结构如下：计划的DAG是级别2的DAG，而级别1和0的DAG是非计划的。0级DAG使用ECSOperator调用预定义的弹性容器服务( ECS )任务，调用定义在ECS任务中的Docker容器中的Python脚本。2级DAG在第1级DAG上等待完成，而后者依次
浏览 6提问于2021-10-12得票数 0
回答已采纳
我在我的IDE中寻找运行/调试任务和dags的最佳方法。我看到有两种方法可以这样做。我可以在调试模式下运行airflow test命令，用于特定的进程和可选的任务。其他方法是使用DebugExecutor并运行特定的dag。我看到这两种方法都要求气流数据库已经启动并运行，并且所有池都配置好了(可能还需要队列)。我的问题是：
这两者之间的主要区别是什么？airflow test在幕后使用DebugExecutor吗？是否有一种方法可以在
浏览 5提问于2020-11-29得票数 5
回答已采纳
我和气流一起工作已经有一段时间了，这是一位同事建立的。最近我遇到了几个错误，这要求我更了解如何修复气流中的某些东西。
我确实理解这三个过程是什么，我只是不理解在我运行它们时所发生的基本事情。当我运行其中一个命令时会发生什么？我能在什么地方看到他们在跑吗？如果我运行这些命令之一，这是覆盖旧的new服务器/调度程序/工作人员还是添加一个新的？此外，如果我运行airflow webserver，屏幕将显示正在发生的一些事情。我可以简单地通
浏览 0提问于2018-06-27得票数 10
回答已采纳
我开始使用Apache气流，并试图在气流中设置一个事件驱动的DAG。我的事件是位于Linux目录中的一个文件。该文件可以在一天中多次登陆。我正在使用操作符进行文件监视。我的要求是，每当文件(同名)在目录中登陆时，Dag就应该启动。
我正在阅读正式的日程安排文档，根据我的理解，使用选项，我可以根据事件使Dag在外部触发，并且可以根据该外部事件在一天中多次触发。
浏览 4提问于2019-11-03得票数 1
回答已采纳
2回答
如何运行指定次数的气流dag？但是，需要维护当前的计数和状态。需要专家的意见，有没有其他深刻的方法来运行气流DAG X次？谢谢。
浏览 7提问于2018-12-14得票数 3
1回答
我在服务器上安装了气流1.10.12，我已经启动了一个带有触发器dag配置的dag，即json。我知道如何在我的dag代码中访问配置，但我想在气流UI中获得它。我该去哪看看？
浏览 5提问于2022-05-24得票数 0
回答已采纳
，当应用程序在前台和后台时，它应该总是侦听触发器。在为两种环境(Android、iOS)添加正确的权限后，如KnowledgeCenter链接所述：
我已经在Android中测试了这个应用程序，当它在前台和后台时，它可以正常工作，当地理位置触发器被获取时，我只需在LogCat中记录一条消息。然而，当我在模拟器中检查隐私设置时，它表明应用程序有权限获取位置“始终、在前台和后台”！！请建议，如果有其他设置，应该使其在iOS中工作，如果这是
浏览 4提问于2015-03-10得票数 0
我得到了以下气流问题：airflow:2.3.1Docker组成芹菜ExecutorWorker，and服务器，调度器和触发器在不同的容器中，码头组成托管在Ubuntu上。在我的EC2实例中，我获得了更多的vCPU和微调的
浏览 5提问于2022-07-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
