腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Airflow
导入
错误
-
UI
中
的
中断
dag
消息
airflow
、
airflow-scheduler
我修改了一个
DAG
文件,在
UI
中
,我看到它开始抱怨
导入
stmt
的
DAG
msg损坏。奇怪
的
是,import之前是存在
的
,并且在我更改之前工作得很好。我能够list_
dag
(命令行界面),手动运行此
DAG
任务,我没有看到任何问题与
DAG
文件。想知道我如何解决这个问题吗?我查看了元数据表import_error,我看到了这条
消息
,并且“id”列正在不断更新。因此,我不确定从这个imp
浏览 10
提问于2020-04-09
得票数 0
回答已采纳
1
回答
Airflow
显示
DAG
导入
错误
(IndexError:列表索引超出范围),但
DAG
工作正常
python
、
bash
、
airflow
/validation/runner.py arg1 arg2",我给出了两个在py脚本中使用
的
args。因为我对不同
的
args使用相同
的
脚本。但是,气流用户界面显示了有关args
的
错误
:
中断
DAG
: /opt/
airflow
/dags/scripts/validation/runner.py跟踪
浏览 3
提问于2022-07-20
得票数 2
回答已采纳
2
回答
ro如何清除气流
中
不需要
的
破碎
DAG
airflow
我在我
的
sql_test.py
中
写了一些
错误
,并运行了python sql_test.py,
错误
是‘没有模块名为xxx',而在web
中
,它显示了一个红色
错误
的
DAG
。然后我运行
airflow
list_dags,同样
的
错误
再次发生,.This很奇怪,我不知道发生了什么。我试图运行
airflow
delete_dags sql_test,但是没有这样
的
id
浏览 1
提问于2019-07-26
得票数 1
回答已采纳
1
回答
Airflow
UI
无法找到提供程序模块
python
、
airflow
我已经在运行Ubuntu和python 3.8
的
服务器上安装了
Airflow
。我正在尝试在
Airflow
UI
中
导入
一个简单
的
dag
来列出存储桶
中
的
文件。
UI
中
导入
失败,并抛出异常:我已经使用pip安装了
浏览 40
提问于2021-05-23
得票数 1
回答已采纳
1
回答
与Cloud Composer
的
松散集成-损坏
的
DAG
没有名为'slackclient‘
的
模块
google-cloud-platform
、
airflow
、
slack-api
、
google-cloud-composer
SlackAPIPostOperator具有slackclient依赖项,我们使用以下命令将其直接安装在工作节点上: sudo python3 -m pip install apache-
airflow
我们必须在工作节点上安装,因为Cloud composer
UI
上
的
pypi包安装选项反复超时。 模块
导入
语句在工作节点上工作得很好。但是,composer仍会报告损坏
的
DAG
并显示
错误
消息
:Broken
DAG
: [/hom
浏览 17
提问于2021-04-16
得票数 0
4
回答
如何查看气流
DAG
的
完整路径?
airflow
在气流网络接口中,我可以查看
DAG
的
列表。如果单击其中一个
DAG
,我可以看到
DAG
的
不同视图或
DAG
的
代码,在details选项卡
中
,我可以看到DAGs文件
的
名称,但看不到路径。我也尝试过
airflow
list-dags,但这也不能提供我想要
的
信息。 我可以在web接口中看到一个
DAG
,但是我找不到它在文件系统
中
的
位置。是否有方法从气流网络接口
浏览 8
提问于2017-07-31
得票数 0
回答已采纳
1
回答
DAG
导入
在两种方式上
的
区别?
airflow
我正在尝试创建动态
的
dag
,但似乎在一分钟内失败了。我偶然发现在两个不同
的
地方创建了
DAG
对象: from
airflow
import
DAG
确实让我感到困惑,因为在相同
的
文档中有两种方法来实例化
DAG
对象。
浏览 0
提问于2018-06-22
得票数 0
1
回答
删除气流
DAG
python
、
airflow
不过,我尝试删除气流
中
的
某些
DAG
(手动删除,只使用底部),但删除后得到
消息
(因此物理
DAG
不再存在)。
中断
DAG
: /usr/local/
airflow
/dags/reports_general/templates/data_quality_report_
airflow
__.py无效控制字符位于:第2行第
浏览 3
提问于2022-03-13
得票数 0
1
回答
为什么这个获得气流上下文
的
代码会在
DAG
导入
上运行?
python
、
google-cloud-platform
、
airflow
、
google-cloud-composer
以前,我有在
DAG
步骤
中
获取这些参数
的
代码(我使用
的
是气流2
中
的
Taskflow API ) --类似于这样:from
airflow
.decoratorstasks here现在,这会在
DAG
导入
上
中断
,出现以下
错误
(更改名称以匹配上面的示例)
浏览 5
提问于2021-10-21
得票数 3
回答已采纳
2
回答
从
dag
_bag
中
删除后,无法从
airflow
UI
中
删除
dag
airflow
我从
airflow
dag
_bag和相应
的
.pyc文件
中
删除了
dag
。当我尝试从
airflow
UI
中
删除相同
的
dag
时,它显示此
错误
:
Dag
id MY_
DAG
_ID仍然在DagBag
中
。首先删除
DAG
文件。我使用
的
airflow
版本是1.10.4,即使在重新启动
airflow</
浏览 2
提问于2019-12-03
得票数 1
2
回答
我们如何进口气流
中
的
气垫?
python
、
airflow
、
airflow-scheduler
我是气流
的
新手,我试图
导入
我自己
的
定制jar作为
DAG
,它是用Talend 生成
的
,当我通过终端
导入
DAG
时,没有显示
错误
,也没有将我
的
DAG
添加到气流
UI
中
的
DAG
列表
中
。以下是我
的
.py文件代码:from
airf
浏览 0
提问于2019-04-29
得票数 0
回答已采纳
1
回答
获取
dag
的
url,以便在空闲时发出警告
消息
airflow
我用
的
是arflow 2.2.1。我有一个守护程序,当它失败时,它会发出警告信息。retry_delay': dt.timedelta(seconds=10),}from
airflow
.providers.slack.operators.slacktext=msg, ).execute(context=None) re
浏览 5
提问于2022-11-17
得票数 0
回答已采纳
1
回答
我无法从气流中
导入
airflow
.operators.print_text_old。
python
、
airflow
我
的
命令是成功安装了气流,但我无法从气流中
导入
airflow
.operators.print_text_old。
错误
消息
说: from datetime import timedeltafrom
airflow
.models import
D
浏览 0
提问于2021-06-09
得票数 2
3
回答
如何与Pywikibot一起使用气流
python
、
airflow
、
pywikibot
当在
DAG
文件(或
DAG
文件
导入
的
模块)中
导入
pywikibot时,
DAG
就会
中断
,从而在webserver
中
抛出
错误
:from
airflow
import
D
浏览 10
提问于2019-11-29
得票数 2
3
回答
气流网络服务器不能打开
DAG
?
airflow
在气流网络服务器
UI
中
无法打开
DAG
时出现问题。
airflow
list_dags然后转到webserver,刷新
UI
中
的
dag
,将
DAG
状态切换到" on ",单击
DAG
尝试查看图形视图。
中断
DAG
: /home/气流/气流/dags/mydag.py超时,PID: 44818
浏览 5
提问于2020-01-16
得票数 0
回答已采纳
1
回答
当试图使用S3存储从Redshift到RedshiftToS3Operator
的
SQL查询输出时,气流异常
amazon-web-services
、
airflow
、
amazon-redshift
我已经创建了一个红移连接在气流
中
,附在屏幕截图中。在此之后,我将RedshiftToS3Operator
导入
到
DAG
中
以运行红移查询,并将csv存储在s3
中
。from datetime import timedelta, datetimeimport
airflow
from
airflow
.operators.dummy import DummyOper
浏览 9
提问于2022-03-29
得票数 1
回答已采纳
1
回答
ImportError :无法
导入
DAG
气流
python
、
python-2.7
、
airflow
我有简单
的
代码,我正在尝试从
airflow
导入
DAG
from
airflow
.operators import BashOperator,S3KeySensortimedelta yesterdayDate = yesterday.strftime('%Y-%m-%d') 但是,我收到了
导入
错误
浏览 2
提问于2018-05-02
得票数 6
回答已采纳
2
回答
你好阿帕奇气流不工作
的
世界
airflow
我正在学习Apache气流,并尝试编写hello world版本
的
它。我已经用python版本3.8和下面的包含
dag
和任务
的
代码安装了
airflow
版本2.0import logging 我可以在
UI
中看到<e
浏览 7
提问于2021-02-07
得票数 2
回答已采纳
0
回答
Airflow
-从父文件夹
导入
python
、
airflow
简介:我可以通过$ python my_
dag
.py运行
dag
,但在
Airflow
UI
中
,它显示
错误
No module named 'my_file_to_be_imported'。我有一个包含dags和lutils (来自我
的
自定义文件夹)
的
容器,git文件夹在
airflow
home
中
映射为卷,如下所示: |──── dags──
浏览 3
提问于2018-07-17
得票数 2
4
回答
Apache
Airflow
DAG
无法
导入
本地模块
python
、
airflow
、
apache-airflow
我似乎不了解如何将模块
导入
到apache
airflow
DAG
定义文件
中
。例如,我想这样做是为了能够创建一个库,使具有类似设置
的
声明任务不那么繁琐。这是我能想到
的
重复这个问题
的
最简单
的
例子:我修改了
airflow
教程(https://
airflow
.apache.org/tutorial.html#recap),只需
导入
一个模块并从该模块运行一个定义defintion
浏览 197
提问于2017-12-28
得票数 29
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
数据作业自动化调度 AirFlow
大数据任务调度平台选型建议
没看过这篇文章,别说你会用Airflow
大规模运行Apache Airflow的经验和教训
AWS推出Apache Airflow全托管工作流MWAA
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券