0回答
简介:我可以通过$ python my_dag.py运行dag，但在Airflow UI中，它显示错误No module named 'my_file_to_be_imported'。我有一个包含dags和lutils (来自我的自定义文件夹)的容器，git文件夹在airflow home中映射为卷，如下所示： |──── dagsmy_dag.py文件需要读取lutils文件夹中的内容。'
我如何解决这个问题，使<
浏览 3提问于2018-07-17得票数 2
我有以下文件夹结构 |_dag/airflow/ | |_ mydag.py |_myprojects/
|_proj
浏览 51提问于2021-05-19得票数 0
我使用的是Windows 10、python 3.6.4和apache-airflow 1.10.2import airflow import airflow
(No Error
浏览 2提问于2019-03-27得票数 3
1回答
下面是我的文件夹结构：->deployment_pipelinesrc ->__init__.py,airflow_dag.py->db_connector_mlflow现在，我正在尝试将函数start_final_train从train_pipeline.py(位于文件夹deployment_pipelin
浏览 0提问于2020-05-15得票数 0
它需要我在我的DAG代码中添加以下导入语句： from airflow.providers.google.cloud.operators.pubsub import (PubSubDeleteTopicOperator, PubSubPublishMessageOperator,from airflow.providers.google.cloud.sensors.pubsubimport PubS
浏览 28提问于2020-01-30得票数 1
回答已采纳
首先是在(first_plugin)中创建一个插件文件夹，一个项目，然后创建一个python文件(first_operator.py)。如何导入正确的插件是一个挑战。导入自定义操作符有很多可能的方法。我会展示我试过的。在Pycharm导入过程中，这些方法都没有帮助我。例如,但是我确信，如果我忽略导入行，并将我的自定义守护进程放到dags文件夹
浏览 1提问于2020-06-07得票数 4
我现在有一个DAG，它依赖于其他模块，而且我遇到了一个ModuleNotFound错误，它阻止了我导入DAG。from my_project.common_modules.module1 import *dags| my_project
| __ini
浏览 15提问于2022-07-08得票数 0
回答已采纳
我正在尝试对我在Airflow中编写的一些函数运行pytest。我使用的是Python 3.8，顺便说一下。文件夹结构为 airflow -- includes -- functions.py
-我尝试了airflow文件夹中的python -m pytest tests，同样的导入错误。 我对导入模块不是很熟悉，如果能帮助我解决这个错误，我将不胜感激。
浏览 50提问于2021-08-02得票数 1
回答已采纳
我有不同的文件夹：(其中有mycode.py)和mycode.py将使用另一个名为helpers的文件夹中可用的python脚本。helpers.useful_functions import formatting_date bash_command=f"cd /opt/airflowpreprocessing_data/mycode.py " f"--query-name mycode&q
浏览 2提问于2022-08-18得票数 0
我无法将通用代码移出airflow使用的dag目录。我在中查找并找到了。 |──── dags │ └── dag_2.py
├── common
浏览 0提问于2017-07-13得票数 10
我有以下结构：我尝试在inbound_layer的一些文件中导入脚本，如下所示：然而，我在Airflow web上收到以下错误信息：有什么想法吗？
浏览 92提问于2019-05-15得票数 4
回答已采纳
我为不同的python项目设置了不同的airflow DAG，即一个父DAG文件夹/vol/dags，以及基于不同python项目的DAG的子文件夹：/vol/dags/project1/project1例如，project1.py从同一目录下的另一个python文件导入函数，即/vol/dags/project1/mycalculator.py。但是当我启动airflow webserver时，我得到了一
浏览 0提问于2017-04-05得票数 9
2回答
但是，当我试图在与my_scripts目录相同的级别从my_dags目录导入函数时，我会得到以下错误：airflowdags| ├── Dockerfile ├── docker-compose.yml├── trading_pipeline── __init__.py| ├── __init__.py├── __
浏览 12提问于2022-05-11得票数 0
我需要创建一个自定义的气流运算符，我应该能够在气流模板中使用它(用python编写)，它运行在云编写器中……
浏览 0提问于2018-11-28得票数 7
回答已采纳
2回答
我已经将钩子放在$AIRFLOW_HOME/plugins目录中。home__ubuntu__airflow__plugins_snowflake_hook2.SnowflakeHook2'>]snowflakepluginmodule <module 'airflow
浏览 2提问于2018-04-18得票数 5
1回答
我正在使用Dockerfile和Dockerfile运行apache气流，并且我有以下气流文件夹结构： example_dagpf_utilsfunction _init_.py我已经从文件夹实用程序中创建了一个包，以便能够按照中的说明导入它的函数在dags和插件代码中。但是，由于不存在模块，snowflake_o
浏览 2提问于2021-08-09得票数 1
我创建了一个utils文件夹，并在其中创建了一个实用程序类，供不同的DAG使用。我试图在dags/bq_ to _mysql/umc_cg_service_sync.py中导入这个类，我试图导入BigQueryToMySql类。/dags:/opt/airflow/dags - ./plugins:/opt/
浏览 12提问于2022-09-14得票数 0
我的自定义operators使用我的自定义hooks，所有导入都相对于顶级文件夹plugins。# my_operator.py但是，当我尝试将我的整个存储库移动到插件文件夹中时，在运行airflow list_dags之后，我会收到一个导入错误，说明找不到plugins。我读了一些关于它的内容，显然是气流将插件加载到它的核心模块中，这样它们就可以被导入，就像from
浏览 1提问于2019-08-19得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
