我刚接触airflow并使用1.10.12版 我已经创建了一个DAG来连接到Azure Data Lake，并将文件从那里复制到GCS。然而，我一直收到这个错误消息e。
浏览 6提问于2021-06-28得票数 0
我有多个带有行from airflow.operators.mssql_operator import MsSqlOperator的DAG，但是一旦调度程序和and服务器启动，我将得到以下错误： File "/opt/airflow/dags/>
from <
浏览 16提问于2022-03-28得票数 0
回答已采纳
1回答
plugins snowflake_operator.py --> from pf_utils.db import get_primary_keys名称: pf-utils版本: 0.0.0摘要:未知主页:未知作者:无作者-电子邮件:无许可:未知位置: /home/airflow/
浏览 2提问于2021-08-09得票数 1
2回答
我使用的是下面的停靠-组合映像，我从以下位置获得了这个映像：x-airflow-common: &airflow-common AIRFL
浏览 26提问于2021-06-05得票数 17
回答已采纳
我必须完成一个共享气流1.10项目，因此我克隆了存储库，其结构如下：├── airflow.cfg├── dags
│ ├── dags_here.py:文件"/home/xxx/venv/lib/python3.8/site-packages/airflow/plugins_manager.py"，第218行，在m=imp.load_source(命名
浏览 6提问于2021-06-01得票数 1
回答已采纳
我的一个工作流使用DataprocClusterCreateOperator在不同的项目中创建了一个Dataproc集群，然后尝试使用来自airflow.contrib.operators.dataproc_operator模块的DataProcPySparkOperator向该集群提交PySpark作业。例如，我希望能够传递一个project_id，但当任务运行时，我最终得到了一个404错误： from airflow.contrib.operators.dataproc_operator import
浏览 22提问于2020-08-13得票数 0
回答已采纳
我已经在运行Ubuntu和python 3.8的服务器上安装了Airflow。我正在尝试在Airflow UI中导入一个简单的dag来列出存储桶中的文件。from airflow import DAG
from airflow.providers.amazon.aws.operators.s3_copy_object import S3CopyObjectOperatorfrom airflow.providers.amazon.aws.operators.s3_list import S3ListOpe
浏览 40提问于2021-05-23得票数 1
回答已采纳
我在Oracle机器上运行Airflow 2.3.0，当我在两个不同的终端上运行命令(命令airflow scheduler和airflow webserver)时，一切正常。但是，当我尝试以守护进程(命令airflow scheduler -D和airflow webserver -D)的形式运行服务时，只有调度程序命令才能工作。我配置了气流(因此也是webserver_conf.py文件)，通过OAuth身份验证来工作，添加了自己的提供程序并扩展了
浏览 21提问于2022-06-29得票数 1
回答已采纳
目前，我正在尝试使用微软提供的OfficeExtension.Promise填充来开发Office外接程序。不幸的是，到目前为止，我无法使它发挥作用。据我所知，这些只在WordApi 1.2和ExcelApi 1.2中提供。因为我找不到提供这些api的单独的节点模块，所以我推测这些模块都包含在普通的'@microsoft/office-js‘节点模块中。此外，我还安装了office-js类型。节点模导入语句
到目前为止，
浏览 3提问于2017-12-18得票数 0
回答已采纳
1回答
我知道Airflow有自己的日志记录功能，但我发现它们太冗长了，无法浏览。有没有办法为所有任务创建我自己的日志函数，使日志只包含我的自定义日志消息？
浏览 65提问于2021-07-21得票数 0
回答已采纳
2回答
当我运行这个程序时，我会收到一个“坏了的守护程序没有命名模块松弛客户端”。我检查了我的代码并设置了我的闲置帐户。from airflow.operators.slack_operator import SlackAPIPostOperator
浏览 0提问于2018-11-01得票数 2
回答已采纳
我正在考虑使用Apache-Airflow。我看了一下文档，现在我正在尝试使用Airflow实现一个已经存在的管道(自制框架)。 所有给出的示例都是简单的单模块DAG。但在现实生活中，您可以拥有一个提供(复杂)管道块的版本化应用程序。DAG使用这些块作为任务。基本上，应用程序包安装在专用的虚拟环境及其依赖项中。 好的，那么，不，现在，你如何用气流来堵塞它？airflow是否应该安装在应用程序virtualenv中？然后，此应用程序管道
浏览 26提问于2019-12-24得票数 0
在C#中，什么等同于string模块，该模块在Microsoft.VisualBasic命名空间中定义字符串助手方法。它提供了一些有用的过程，可以用来执行字符串操作，例如Left。
浏览 2提问于2014-01-27得票数 0
回答已采纳
1回答
目前，我使用的气流版本: 1.10.10
打开到airflow/logs文件夹后，有许多文件夹是根据DAG名称命名的，但是有一个名为调度程序的文件夹，当打开该文件夹时，包含以日期格式命名的文件夹(例如，2020/07/08 )，直到我首次使用airflow.After搜索多个论坛时，我仍然不确定该文件夹日志用于干什么。无论如何，问题是我一直在想，删除调度器文件夹中的内容是否可以，因为它占用了很大的空间，不像根据DAG名称命名的文件夹的其余部分(我假设每个DA
浏览 3提问于2020-07-08得票数 5
回答已采纳
我的连接有以下额外的参数：{"key_file": "/home/airflow/key_files/some_key", "no_host_key_check": "true"}。-----END OPENSSH PRIVATE KEY----- 现在，当我尝试创建一个钩子时，我得到了以下错误： >>> from airflow.contrib.hooks.sftp_hook importHost: my_sftp.co
浏览 68提问于2020-07-08得票数 1
基本上，我使用的是为使用pyodbc和cx_oracle驱动程序和PythonVirtualenvOperator而修改的puckel/docker-airflow Docker镜像，但是当我尝试创建driver=/opt/microsoft/msodbcsql17/lib64/libmsodbcsql-17.7.so.1.1&domain=domain&password={}&login=userformat(_pass))
target_frame.to
浏览 11提问于2021-02-11得票数 2
回答已采纳
我正在考虑使用Apache Airflow，但有一些疑问。我需要编排的python微服务很复杂，并且有许多不同的依赖项，因此，如果在Airflow中使用python操作符实现，那么整体解决方案将是巨大而棘手的。您是否看到了使用Airflow来满足这些需求的任何方便的选择？使用Kafka或任何其他消息传递系统可能是更好的解决方案？
谢谢
浏览 0提问于2020-06-13得票数 0
1回答
在这个资源中，我需要一个程序集(Microsoft.SqlServer.Smo.dll)。我尝试使用清单文件加载程序集，如下所示：RequiredAssemblies = @("Microsoft.SqlServer.Smo.dll")错误消息的图片：
如何将程序集加载到
浏览 3提问于2017-10-12得票数 0
3回答
避免依赖码头
、、
我用Python构建了一个AI应用程序，涉及大量的Python库。在这一点上，我想运行我的应用程序在一个码头容器，使AI应用程序服务。
，我有哪些关于依赖程序的选项，以便自动下载所有必需的库？
浏览 3提问于2020-04-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
