在升级到气流2之后，我在一些DAGs中得到了这个错误：
ImportError: cannot import name 'BashOperator' from 'airflow.operators'
浏览 7提问于2021-01-05得票数 2
回答已采纳
我正在尝试将我的气流日期从一位数转换为两位数。在我使用{{ execution_date.month }}的时候，我的月份变成了1，但是希望它成为01。 int对象‘没有属性'strftime
浏览 4提问于2022-01-20得票数 -1
回答已采纳
我正在尝试通过Bash操作符启动一个进程。bash =BashOperator( bash_command='airflow trigger_dag -e"{{ next_execution_date }}" some_dag_id', ) 我知道Airflow使用钟摆来管理日期时间，所以通过查看文档
浏览 20提问于2020-01-30得票数 1
这是我尝试过的： from airflow import DAGfrom airflow.operators.dummyfrom airflow import DAGfrom airflow.utils.dates impo
浏览 18提问于2021-05-02得票数 1
我最近开始使用Docker airflow (puckel/docker-airflow)，这让我做了噩梦。from airflow import DAGfrom datetime(task_id=&quo
浏览 0提问于2019-08-11得票数 2
我对气流和Python很陌生。我想读取一个文件从HDFS在气流PythonOperator。我想在dag.py文件(包含DAG的python)中读取这个文件。
浏览 1提问于2020-10-14得票数 0
我不知道如何处理这个问题--其他与ModuleNotFoundError有关的帖子都是通过重新安装相关的包来解决的，但是很明显，这不是问题，因为bash操作符示例运行。那么，我的问题是如何安装气流？[2020-12-23 01:02:24,705] {dagbag.py:259} ERROR - Failed to import: /home/pi/airflow/dags/dag_clist.py_bootstrap>", line 219, in _call_with_frames_rem
浏览 0提问于2020-12-23得票数 3
回答已采纳
1回答
Broken DAG: [/root/airflow/dags/param_test.py] invalid syntax (param_test.py, line 13)
airflow schedulerfrom airflow import DAG
from airflow.modelsimport Va
浏览 1提问于2018-09-05得票数 4
回答已采纳
我似乎到处都找不到那个文件。是因为我在Windows上使用WSL吗？下面是我的简单脚本： import os
from airflow.operators.bash_operatorimport BashOperator
defaul
浏览 24提问于2020-12-08得票数 1
回答已采纳
我的理解是：“如果xcom_push为真，那么当bash命令完成时，写入标准输出的最后一行也将被推送到XCom。” 但我的目标是从bash命令中获得一个特定值，而不是最后编写的一行。from airflow import DAGfrom datetime importdatetime,timedelta
from airflow.operators.python_operator imp
浏览 40提问于2021-10-31得票数 0
回答已采纳
1回答
import airflowfrom airflow.operators.bash_operator import BashOperatort1 = BashOperator(
task_id='%
浏览 4提问于2018-02-09得票数 1
回答已采纳
Begin Test Dag End ****airflow.exceptions.AirflowException:找不到dag_id : sample_dag。* 执行DAG内的调试打印，但不调用Bash脚本(不生成脚本日志)。import datetime as dtfrom airflow.operators.bash_operator import BashOperator"', dag=d
浏览 18提问于2019-01-15得票数 0
我正在创建我的第一个使用subdag的dag，并导入subdag运算符 `from airflow.operators.subdag import SubDagOperator` 然而，我一直收到流错误"Broken : /usr/local/airflow/dags/POC_Main_DAG.py没有名为‘airflow.operators.subdag’的模块“ 我还尝试导入虚拟操作符，但得到了相同的错误from airflow.operators.b
浏览 8提问于2021-01-06得票数 2
回答已采纳
例如，假设我们有一个bash操作符： task_id="bash_task",)from airflow import DAG
from airflow
浏览 2提问于2022-08-10得票数 0
回答已采纳
1回答
我正在尝试在Airflow中运行一个简单的BASHOperator任务。DAG在触发时以树和图形视图的形式手动列出任务，但任务始终处于未启动状态。from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.bash
浏览 72提问于2021-06-12得票数 1
我正在使用apache airflow和BashOperator。每个BashOperator执行一个python脚本。例如：from airflow.operators.bash_operator import BashOperator schedule_interval='0 2 */2 * *',
浏览 18提问于2020-05-20得票数 1
当我通过BashOperator运行Bash命令时，我遇到了以下问题：Traceback (most recent call last):
File "/home/airflow//site-pa
浏览 11提问于2019-11-14得票数 3
我使用root帐户在集群上安装了Airflow。我知道这是不好的练习，但它只是测试环境。我创建了一个简单的DAG：from airflow.operators.bash_operator import BashOperator
from datetimecreate_directory', description='simple create directory workflow', start_date=datetime(2
浏览 9提问于2017-10-30得票数 3
回答已采纳
1回答
您好，我使用Linux子系统在window系统中成功安装了airflow。 我已经安装了java，并在环境变量中设置了它的主路径。通常我可以从命令行运行任何java程序。我正在尝试使用airflow代码运行java程序。但我得到错误java命令找不到。 下面的代码是我用来处理气流的。import airflowfrom airflow.operators.bash_operator import BashOper
浏览 21提问于2020-10-29得票数 2
回答已采纳
我们希望使用Bash操作符来执行气流命令。遵循关于Bash运算符的文档。可以将环境变量添加到bash操作符中，以便在命令中使用它们。
是否也有方法从空气流配置中添加作为环境变量存储的值？
浏览 1提问于2022-11-14得票数 -1
回答已采纳
云服务器
ICP备案
对象存储
云点播
智聆口语评测
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号