当我看到airflow最后一次运行日期时，它会显示最后一次运行日期。当我将鼠标悬停在"i“图标上时，它会引起我的注意，因为它显示了正确的日期。有什么办法可以解决这个问题吗？听起来像是胡说八道，但我最终还是用它来对我的数据进行QA。
浏览 29提问于2019-07-25得票数 2
回答已采纳
我在OS window server 2019上运行docker desktop 3.3.1和Linux容器。Airflow在docker桌面上使用docker-compose文件启动，就像提到的here一样，它正在成功运行。但是，在一段时间后在此airflow上启动dag时，我在airflow the服务器上收到以下消息： “排定程序似乎没有运行。最后一次心跳是在X分钟前收到的。“ 有时airflow</e
浏览 49提问于2021-04-22得票数 0
我使用‘`docker’在AWS ECS中运行AWS ECS。我知道这是可以避免气流调度程序重新启动吗？我们应该使用airflow.cfg而不是env variable吗
浏览 2提问于2021-09-12得票数 0
回答已采纳
我有几个任务可以同时运行。当他们完成后，我需要运行一个最后的任务。我尝试使用这样的任务分组来完成这个任务：from airflow.utils.task_group import TaskGroup
task1 -> final_task task2 -> final_task
我想要的是任务组并行运行，当它
浏览 6提问于2022-05-30得票数 1
回答已采纳
我们有一个按小时运行的气流数据集，任务更新和覆盖BigQuery中的日期分区表。在对这些表的查询和/或模式进行调整之后，我们想要回填几天的现有分区，但是回填所有运行都是巨大的浪费，因为每小时运行一次只会覆盖相同的分区24次，然后再转到第二天。我们可以使用airflow list_dag_runs列出所有运行并筛选出每天的最后一个
浏览 3提问于2020-06-10得票数 0
回答已采纳
目前，我正在从Spring XD作为我的工作流和运行时环境迁移到Spring Cloud DataFlow和Apache Airflow。我想在Airflow中创建工作流，并使用自定义Airflow operator通过REST-API在Spring Cloud DataFlow服务器上运行Spring Cloud任务。不幸的是，DataFlow没有在此请求中返回作业执行ID，以创建监视应用程序的简单方法。有没有办法以同步的方式获取这
浏览 8提问于2017-01-27得票数 1
我根据设置了我的气流(2.0.1)错误：
Traceback (most recent
浏览 7提问于2021-05-03得票数 1
回答已采纳
12回答
DAG在Web中不可见
、、、
我是Airflow的新手。我遵循一个教程，并编写了下面的代码。from airflow import DAGfrom datetime importprint_the_context', python_callable=correctness_prediction,在运行脚本时，它不会显
浏览 14提问于2016-08-17得票数 34
回答已采纳
当有任务运行时，Airflow将弹出一个通知，说明调度程序似乎没有运行，并一直显示到任务完成：我的任务有点重，可能要运行几个小时。
浏览 87提问于2019-08-27得票数 39
2回答
我想在指定的日期运行一个简单的DAG。我正在努力改变开始日期、执行日期和回填之间的差异。运行DAG的命令是什么？以下是我尝试过的：当我第一次运行该命令时，任务正确地执行，但是当我再次尝试时，它没有工作。下面是我运行的另一个命令：
airflow backfill dag_1 -s 2017-1
浏览 7提问于2017-01-23得票数 20
回答已采纳
我的DAG是这样的，
t1 = BashOperator(task_id = 'testing_task',bash_command = 'python /home/ubuntu/airflow/dags/scripts/test.p
浏览 30提问于2018-02-08得票数 1
回答已采纳
我有一个pyspark脚本，它现在工作得很好，我想做的是，我想为每一分钟安排该作业，为此，我使用了Apache Airflow，我为airflow创建了一个.py文件，如下所示： from airflowimport osimport airflowfrom airflow.operators.dummy_operatorspark-2.4.0-bin
浏览 24提问于2019-04-08得票数 0
我可以使用airflow webserver命令正常启动webserver。但是当我使用airflow webserver -D时，它显示： /data/software/miniconda3/lib/python3.7/site-packages/airflow/config_templates/airflow_local_settings.py:65: DeprecationWarning: The elasticsearch_h
浏览 199提问于2019-12-25得票数 0
5回答
我正在尝试使用airflow来定义我想要从命令行手动触发的特定工作流。 "DAG_NAME", schedule_interval=None,default_args=args)airflow trigger_dag DAG_NAME
什么都不会发生。调度程序正在另一个线程中运行。任何方
浏览 2提问于2016-05-05得票数 24
1回答
我的Airflow per服务器已启动并运行，因为其他作业正在按计划运行。我添加了一个新的DAG，每5分钟执行一次。添加后，我第一次手动运行它，它完成了。然而，在那之后，它不会每隔5分钟再次运行一次。Dag代码如下 from airflow import DAGfro
浏览 12提问于2019-06-11得票数 0
我有一个正在运行的Airflow服务器，并且我正在airflow.cfg中进行配置更改，这需要运行airflow initdb。第二次运行airflow initdb命令是否会破坏现有的表，或者它只会根据新的配置执行更改？
浏览 12提问于2019-07-08得票数 1
我有一个CentOS 7实例，我在上面安装了airflow和postgresql。通过以下步骤，最初通过yum安装postgres-server和cont肋骨：
sql_alchemy_conn = postgresql+psycopg2://airflow:airflow@localhost/a
浏览 4提问于2022-06-01得票数 1
2回答
在WSL上安装和运行气流
、、、
我按照中的流程在WSL (Windows 10)下在Ubuntu中安装了气流。但是，在运行airflow db init时，我会得到以下错误：(airflow_env) sultani@Khalid:~/c/users/administrator/airflo
浏览 6提问于2022-06-08得票数 1
回答已采纳
嗨，我正在上一个关于如何使用Airflow的datacamp课程，它展示了如何在访问Airflow Web界面后创建dags。 是否有在Airflow Web界面中创建帐户的简单方法？我对如何做到这一点非常迷茫，或者这只是一个企业工具，一旦你付费，他们就会为你提供访问它的权限？
浏览 99提问于2021-05-08得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
