1回答
我想知道如何将参数传递给通过airflow运行的配置单元查询脚本。如果我只想为这个脚本添加一个参数，比如target_db = mydatabase，我该怎么做呢？
浏览 3提问于2018-01-04得票数 1
回答已采纳
1回答
即使将自定义UUID作为run_id传递给气流dagrun，也会得到此错误。运行id已经存在
为了在一秒钟内创建多个DagRun，应该根据文档将参数"replace_microseconds“设置为"false”。但是如何使用CLI命令实现相同的目标呢？我们正在为Apache气流(MWAA)使用Amazon管理的工作流。
浏览 5提问于2022-10-14得票数 0
1回答
我有一个带有test.hql的hql脚本，因为我在查询date='${ env :date}‘中有这样的env变量，如果它是hiveconf或hivevar，我们如何将一个参数传递给hql，比如有人能告诉我们如何传递env变量吗？hive -f --env date='20220526' test.
浏览 1提问于2022-05-26得票数 0
回答已采纳
我试图在气流上运行一个测试任务，但是我一直得到以下错误：
import airflowfrom airflow.operators.hive_operatorimport_lv_data = HiveOperator(
task_id='fct_
浏览 1提问于2018-11-12得票数 1
回答已采纳
我对气流很陌生。我设置了一个气流环境，我的所有服务都是由气流触发的。但是，我打算直接从气流网将程序参数传递给DAG中定义的服务之一。我在气流网触发器上看到以下选项: DAG / conf我想向DAG传递一个json，如下所示，作为我的程序参数：
{"list_key" : ["K1" : "V1", "K2" : "V2&q
浏览 5提问于2022-05-19得票数 1
我想知道op_kwargs和templates_dict在气流中的用法有什么不同，因为两者都是PythonOperator template_fields= ['templates_dict', 'op_args
浏览 11提问于2022-06-22得票数 1
回答已采纳
我用的是气流1.0.15。它是部署在库伯内特斯集群使用气流官方舵图。我不能把环境变量传递给工人舱。我能够使用executor_config参数将一个configmap挂载到工人舱中。但是我们如何将环境变量传递给工人吊舱呢？
浏览 13提问于2022-03-29得票数 1
2回答
我有两个蜂巢脚本，如下所示：
我们在每个脚本开头设置的选项是相同的。是否有可能以某种方式将它们提取到一个共同的地方(例如，在一个com
浏览 2提问于2016-11-22得票数 3
我正面临着一个问题:如何将参数传递给HQL，以便在查询with in子句中使用像- select id, name from ABC where (id, reg_date) in ('x', 'y')参数具有不同的数据类型string (id)和reg_date (date)。现在，在HQL中，我可以这样写：
hql = "select id, Name from ABC where (id, dat
浏览 3提问于2015-02-03得票数 3
我们正在升级到气流2.0，我有以下任务： cms_ingest = SubDagOperator( task_id='cms_s3ingest', task_concurrency=4)
airfl
浏览 1提问于2021-05-05得票数 1
回答已采纳
1回答
我对数据的查询如下：将last_pipeline_run_time作为参数动态传递给数据融合管道的最佳方法是什么如果你能提出任何其他解决办法，这也是有帮助的，我暂时不使用任何其他调度器(如气流)。
浏览 1提问于2021-06-06得票数 0
回答已采纳
1回答
是否可以通过HTML.ActionLink()将类型的参数传递给MVC中的操作方法。我也不能回传一个基类型来允许子类型在它所在的地方被传递。有没有别的HTML帮助器可以帮上忙？
我能对模型绑定做些什么吗？在将控制传递给
浏览 5提问于2011-04-14得票数 1
回答已采纳
然而，当我想通过start_dt考试时，我遇到了麻烦where report_dt between '{{ params.report_start_dt }}' AND'{{ds}}' monthly_profile = HiveOperator(
hql= mycode.sql我做错了什么，我如何才能达到我所需要的，记住我也想用我每周跑步7天的ds来做这件事？
浏览 10提问于2020-02-05得票数 0
2回答
我使用以下JSON触发气流中的DAG： "outcome_id": "B", "event_id": "D",['outcome'] }}",
'outcome_id': "{{ dag_run.conf['outcome_id
浏览 6提问于2022-03-23得票数 0
我们有一个前端服务器，它直接使用dag执行dags (DagBag()，get_dag()，然后是dag_run())。Dags运行良好，问题是，我们无法找到一种使用特定参数来执行此类dags的方法。我们如何运行一个dag并设置可用于其执行的参数？我们主要是使用PythonOperator。
编辑1:我们的程序是一个Python前端服务器。因此，我们通过另一个Python程序来讨论气流。这意味着我们通过Python触发dags，因此，我们使用DagBag.get_dag
浏览 4提问于2017-07-14得票数 0
我对气流很陌生。我有一个DAG.py，其中我使用一个BashOperator运行一个python脚本。
我不知道如何在我的DAG.py中读取它并将它传递给python脚本作为参数使用。airflow.operators.bash import BashOperator
'Sample_DAG',
descr
浏览 2提问于2022-11-15得票数 0
回答已采纳
2回答
对于我的生活，我不知道如何传递一个参数给我的减速器。在运行作业时，我有两个参数想传递给还原器: startDate和endDate。"\n")我似乎不能将startDate和endDate作为参数传递给我的减速器获取参数的唯一方法是通过类顶部的一个全局变量。我想把它从电话里传进来
浏览 10提问于2013-08-01得票数 3
回答已采纳
1回答
"scripts": { "development": "run-something",npm run dev如何将参数从速记命令传递给常规命令？
浏览 2提问于2017-05-22得票数 1
回答已采纳
我试图在基于用户输入的气流中生成动态工作流。我知道可以选择基于文件和数据库的数据，但在所有这些情况下，工作流将不直接依赖用户输入，如果多个用户正在使用相同的数据，那么在这种情况下也可能会出现问题。为了避免所有这些，我正在考虑将用户输入传递给sub并生成工作流。但是subdag没有从ui传递用户输入的选项。
浏览 3提问于2020-11-30得票数 3
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
