我需要执行一个update查询( Oracle )，该查询有一些来自xcom的参数，所以我需要使用带有oracle Hook的PythonOperator (我不确定，但我不能使用oracle操作符执行此操作我已经使用select查询执行了相同的操作，如下所示： oracle_db = OracleHook(oracle_con
浏览 73提问于2021-04-28得票数 2
为了进一步执行，我需要在另一个任务中使用来自oracleOperator的输出。我遇到的麻烦是，当我把数据拉到另一个任务中并打印出来时，它会给出一个零的结果。没有抛出错误，但没有传递数据。我的代码如下：from airflow.operators.oracle_operator import OracleOperator
from airflow.operators.python_operatorimport PythonOperator
浏览 3提问于2020-03-23得票数 3
1回答
我得到了这个错误：
from airflow.decorators import task
from airflow.providers.oracle.hooks
浏览 24提问于2021-12-15得票数 0
我用芹菜执行器运行气流v1.9.0。我用不同的队列名称配置了不同的工作人员，比如DEV、QA、UAT、PROD。我编写了一个自定义传感器，它轮询源db连接和目标db连接，运行不同的查询，并在触发下游任务之前执行一些检查。对于多个工作人员来说，这一直运行良好。为了调试，我检查了来自气流用户界面:数据分析-> Ad查询的DB连接:从dual中选择1；--这很好from airflow.plugins_mana
浏览 1提问于2019-04-09得票数 0
/site-packages/airflow/hooks/oracle_hook.py", line 210, in bulk_insert_rows with closing(hook.get_conn()) as conn: logging.
浏览 7提问于2020-09-28得票数 0
如何在EMR主群集(由Terraform创建)和Airflow之间建立连接。我在亚马逊网络服务EC2服务器下使用相同的SG、VPC和子网进行了Airflow设置。我需要解决方案，这样Airflow才能与EMR对话并执行Spark submit。
在airflow中，我使用AWS和EMR的UI进行了连接：下面是列出活动和终止的EMR集群的代码，我还可以微调以获得活动的集群：-
浏览 1提问于2019-01-03得票数 6
回答已采纳
我正在尝试使用docker-compose的apache airflow，使用基本的容器容器apache/airflow:2.0.1。我正在学习本教程https://airflow.apache.org/docs/apache-airflow/stable/start/docker.html# 如何运行简单的查询来从SQL Server我试着扩展图像 FROM apache
浏览 13提问于2021-04-12得票数 0
回答已采纳
1回答
我正在尝试连接到一个oracle数据库，并在GCP气流上使用python作业。请注意，我没有在本地计算机上执行这些操作。from airflow.utils.dates import days_ago
from datetime impor
浏览 20提问于2022-01-04得票数 0
我正在尝试在Apache Airflow中使用MySQL。我已经使用PymySQL来查询MySQL数据库，并且还没有安装MySQLDb。因此，我得到了错误： File "/anaconda3/anaconda/lib/python3.6/site-packages/airflow/hooks&
浏览 1提问于2018-09-15得票数 2
SQL查询是Show Tables;dag = airflow.DAG( schedule_interval="@daily",
dagrun_timeout
浏览 1提问于2018-06-18得票数 0
回答已采纳
我无法从Python连接到Airflow的元数据数据库。如果我尝试使用相同的连接，但从Python，它将不会工作。57315b5a登录: root但每当我创建一个DAG并尝试使用各种钩子从PythonOperator触发它时，我总是得到相同的错误消息import PythonOperator
from airflow.
浏览 0提问于2020-11-27得票数 1
我在查询一张很旧的桌子。它包含一些我没有权限更改或创建视图的损坏数据。每当我使用 OracleHook get_records选择数据时，都会收到错误消息"ValueError: YOY-4712超出范围“。from airflow.hooks.oracle_hook import OracleHookimport= o_extract_hook.get_reco
浏览 3提问于2020-07-22得票数 1
回答已采纳
我的选择是：
这不是我渴望做的事。这意味着要支付双倍的存储费用。这就忽略了使用气流的意义。
还有别的选择吗？你建议怎么做？
浏览 2提问于2018-09-03得票数 1
我正在使用MySqlHook从airflow_db建立连接，并且正在执行一些查询，但是我需要在某个地方看到查询的结果(假设日志)，如何查看？这里是示例代码 task_id='basic_mysql', sql="select
浏览 1提问于2019-01-08得票数 5
回答已采纳
我正在使用s3 _ 至 _ 重新移位 _ 运算符位于 https://github.com/apache/incubator-airflow/blob/master/airflow/operators/s3 _ 至 _ 红移 _ operator.py 当我执行它时，得到了以下错误： AttributeError: 'S3Hook' object has no attribute 'ge
浏览 93提问于2018-07-12得票数 2
回答已采纳
0回答
在airflow中显示有关损坏的DAG的信息我尝试使用DAG copy_from_Oracle_to_MySQL.py从/data/airflow/dags中移动文件。但是气流显示的信息
Broken
浏览 1提问于2017-11-30得票数 2
回答已采纳
我需要以编程方式更新我在Airflow中创建的一个变量，但我找不到如何使用代码执行此操作的答案。airflow import DAGfrom airflow.models import Variable@hourly')
column_number = Variab
浏览 27提问于2019-01-05得票数 21
回答已采纳
1回答
我试图通过气流脚本执行数据流jar。为此，我正在使用DataFlowJavaOperator。在param中，当我试图运行以下作业时，我将传递本地system.But中显示的可执行jar文件的路径。{gcp_dataflow_hook.py:108} INFO - Start waiting for DataFlow process to complete. File "/usr/l
浏览 2提问于2017-09-12得票数 2
1回答
我对Airflow非常陌生，我正在尝试使用Oracle操作符执行我的第一个DAG。中却没有显示出来，所以我尝试执行以下命令下面是我的oracle dag的代码：from airflow.operators.oracle_operator import OracleOpera
浏览 2提问于2020-01-17得票数 4
1回答
我正在尝试将DBT与AWS MWAA集成，但出现以下错误： 2021-09-06 07:04:31,290] {{dbt_hook.py:117}} INFO - /usr/local/airflow/.local/bin/dbt run --profiles-dir /usr/local/airflow/dags/dbt/
[2021-09-06 07:04:31,326] {{dbt_hook.py-
浏览 31提问于2021-09-07得票数 2
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
