如何解析Airflow中的嵌套宏
Airflow是一个开源的任务调度和工作流管理平台，它允许用户以编程方式定义、调度和监控工作流。在Airflow中，嵌套宏是一种特殊的宏，它允许用户在宏中使用其他宏。
要解析Airflow中的嵌套宏，可以按照以下步骤进行：
- 确定宏的定义位置：首先，需要确定嵌套宏的定义位置。在Airflow中，宏通常定义在DAG文件中的顶部，或者可以单独定义在一个宏文件中。
- 理解宏的语法：了解宏的语法是解析嵌套宏的关键。在Airflow中，宏使用Jinja模板语言进行定义和解析。Jinja模板语言使用双大括号（{{}}）来标识宏，并使用特定的语法来引用其他宏。
- 确定嵌套宏的引用位置：在需要使用嵌套宏的地方，使用双大括号将宏引用起来。可以在宏引用中传递参数，以便在宏中进行处理。
- 确定宏的执行顺序：当解析嵌套宏时，需要确定宏的执行顺序。在Airflow中，宏是按照定义的顺序进行解析的，因此需要确保宏的定义在宏的引用之前。
- 调试和测试：在解析嵌套宏之前，可以通过调试和测试来验证宏的正确性。可以使用Airflow提供的调试工具，如
airflow test命令，来测试宏的执行结果。
总结起来，解析Airflow中的嵌套宏需要确定宏的定义位置、理解宏的语法、确定嵌套宏的引用位置、确定宏的执行顺序，并进行调试和测试。通过正确解析嵌套宏，可以实现更灵活和复杂的任务调度和工作流管理。在使用Airflow时，可以参考腾讯云的产品文档和示例代码，如腾讯云容器服务（TKE）和腾讯云函数计算（SCF），来了解更多关于Airflow的应用场景和推荐的腾讯云产品。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云函数计算（SCF）：https://cloud.tencent.com/product/scf
相关·内容
我正在将一个托管Airflow的环境从Airflow 1.10.5和Python 2.7升级到Airflow 2.0.1和Python 3.9。 我正在尝试让宏再次工作： /home/ubuntu/airflow/plugins/ben.py包含： from airflow.plugins_manager import AirflowPlugin
def ret_one():
return 1
class AirflowPluginsTest(AirflowPlugin):
name = "ret_one"
macros = [ret_one] 我
浏览 48提问于2021-03-23得票数 1
回答已采纳
我正在尝试使用jinja模板宏在dag中创建dag级变量，但它不起作用。如果我在python操作符下定义它，它就能工作，但是我也需要在以下操作符中使用相同的变量：
BigQueryExecuteQueryOperatorGCSToBigQueryOperatorGCSDeleteObjectsOperator
有什么办法来定义这个吗？变量应在dag_run发生前2天点。
import os
import pendulum
import requests
from datetime import timedelta
from requests.structures import CaseIns
浏览 8提问于2022-03-16得票数 0
回答已采纳
1回答
我需要一个气流宏值，但返回的字符串不是按预期读取的，我得到的只是一个损坏的DAG。我已经在终端中测试了部分脚本，以确定是否有什么问题，但情况似乎并非如此。
我的预期是“2016-06-28T16:51:45.978473-05:00”这样的字符串会变成“2016-06-28T16:51”。
这是密码。这一部分出现在DAG装饰器作用域with DAG(..) as dag:之前。
exec_date = '{{ execution_date }}'
exec_date = re.findall(r"^[\d]{4}-[\d]{2}-[\d]{2}T[\d]{2}:[\d]
浏览 0提问于2021-06-25得票数 1
回答已采纳
1回答
构建和处理宏的最佳实践
、、、、
我正在构建一个IOS应用程序，并希望为用户提供在系统的不同方面使用宏的能力。
例如，我可能有一个简单的宏this：
{include name="some name" pre="some it of htmk" post="some other bit of html"}
这将包括用户正在处理的文档正文中名为"some name“的项的内容。
或者我可能有更复杂的东西，像这样：
{notesForTag name={ListAllTags pre="some bit of html" post="some othe
浏览 0提问于2011-09-11得票数 1
回答已采纳
1回答
目标
我已经部署了在AWS‘上使用气流的稳定的Helm图。我的目标是创建一个信息，允许其他人通过他们的浏览器访问气流网络服务器UI。值得一提的是，我正在使用AWS Fargate部署在EKS上。我与库伯奈特斯的经验是有限的，我以前也没有设置过一只母老虎。
我想做的事
我目前能够通过端口转发(如kubectl port-forward airflow-web-pod 8080:8080)连接到气流网络服务器吊舱。我已经尝试过通过Helm图表(有文档的)来设置“进题”。之后：
运行kubectl get ingress -n dp-airflow我得到：
NAME CLAS
浏览 3提问于2021-01-22得票数 2
回答已采纳
我想知道下面是否是一个有效的方案。
[column class='container-fluid']
[column class='container']
[column class='row-fluid']
[column class='span4'] One [/column]
[column class='span4'] Two [/column]
[column class='span4'] Three [/column]
[/column]
[/column]
[/column]
短代码代
浏览 3提问于2014-03-18得票数 1
回答已采纳
在Python中，有没有办法从Airflow中的一个DAG任务中获取dag_id？
我的目的是删除Task中的表(与dag同名创建的表)。
浏览 3提问于2021-07-14得票数 0
1回答
进口气流塞
、、
目前，我正试图使用气流将数据从Salesforce推送到BigQuery。我是新来的气流，目前我遵循这个链接：
当我试图导入插件from airflow.operators import SalesforceToFileOperator时，
我得到一条错误消息，声明ImportError: cannot import name 'SalesforceToFileOperator'
如何在气流上导入这个插件？
当前目录结构
达格
salesforce_bg.py
插件
airflow-salesforce
__init__.py
hooks
浏览 0提问于2019-04-18得票数 0
回答已采纳
我试着做一个像
add_shortcode( 'test', 'test' );
function test( $atts, $content = null ) {
$html = '<div>'.do_shortcode( $content ).'</div>';
return $html;
}
我尝试了一些像[test][test]this is test[/test][/test]这样的东西，但这不起作用。
如何解决这个问题。谢谢
浏览 7提问于2014-07-25得票数 2
在气流中，如何使用上下文将参数传递给on_success_callback函数处理程序？
这是我的测试代码：
import airflow
from airflow import DAG
from airflow.operators import MSTeamsWebhookOperator
from airflow.operators.bash_operator import BashOperator
from airflow.operators.dummy_operator import DummyOperator
from datetime import datetime
from tr
浏览 4提问于2020-10-27得票数 1
我目前正在访问一个气流变量，如下所示：
from airflow.models import Variable
s3_bucket = Variable.get('bucket_name')
它可以工作，但有人要求我不要使用变量模块，而是使用jinja模板(即)：
s3_bucket = '{{ var.value.bucket_name }}'
问题是，当我在气流模板(例如PythonOperator/BashOperator)中使用它时，jinja可以工作，但是我很难让它以任务流API形式工作。变量被读取为字符串文本。示例：
# Pretend DAG d
浏览 2提问于2022-04-05得票数 2
回答已采纳
我有一个dockerfile
FROM python:3.9.6-alpine3.14
ARG AIRFLOW_USER_HOME=/usr/local/airflow
ENV AIRFLOW_HOME=${AIRFLOW_USER_HOME}
RUN pip install apache-airflow[postgres,ssh,s3]==2.0.0 --constraint https://raw.githubusercontent.com/apache/airflow/constraints-2.0.0/constraints-3.9.txt
#Add aws config pro
浏览 2提问于2021-08-15得票数 2
我最近刚刚安装了带有码头容器的气流2.1.4，我已经成功地设置了postgres、redis、调度器、2倍本地工作人员，以及在同一台机器上的花。
现在我想扩张，并在其他机器上设置工人。
我能够让工作人员启动并运行，below能够找到worker节点，worker正在正确地接收来自调度程序的任务，但是不管任务的结果状态如何，任务将被标记为失败，错误消息如下：
*** Log file does not exist: /opt/airflow/logs/test/test/2021-10-29T14:38:37.669734+00:00/1.log
*** Fetching from: http:
浏览 5提问于2021-10-29得票数 1
回答已采纳
我在试着装上我的气流装置。我的任务是保持环境不变，只需将其移动到码头容器中。我们目前已经在anaconda环境中安装了Airflow和所有的依赖项。所以我所做的就是创建一个自定义的docker镜像来安装anaconda并创建我的环境。问题是，我们当前的环境使用systemd服务来启动airflow，而Docker需要它通过airflow命令"airflow webserver/scheduler/worker“来运行，当我这样运行它时，我得到了一个错误。我在启动调度器后得到错误。 我们的DAG需要一个自定义存储库来帮助与我们的数据库服务器进行通信。在该存储库中，我们使用pathlib
浏览 85提问于2021-01-12得票数 3
回答已采纳
2回答
我正在设置一个分布式气流集群，其中除了芹菜工作人员以外的其他一切都在一个主机上运行，处理工作在多个主机上进行。气流2.0设置使用在气流文档中提供的yaml文件进行配置。在我的初始测试中，当我在同一台主机上运行所有东西时，我让体系结构工作得很好。问题是，如何在远程主机上启动芹菜工人？
到目前为止，我试图创建一个修整版本的上述对接-写作，在这里，我只开始芹菜工人在工人主机，而不是其他。但我在数据库连接方面遇到了一些问题。在经过修剪的版本中，我更改了URL，以便它们指向运行db和redis的主机。
dags、日志、插件和postgresql db位于所有主机都可以看到的共享驱动器上。
我应该如何进行
浏览 19提问于2021-06-30得票数 7
回答已采纳
1回答
我知道已经有一个airflow函数可以将文件从云存储传递到Big Query，正如我所做的，我在脚本中使用GCP进行连接的方式与没有airflow时相同，我调用PythonOperator来调用我在脚本中配置的函数，以读取云存储并将文件中的数据插入到Big Query中，但我收到错误消息：“获得意外的关键字参数'dag'”
这似乎很容易解决，但我真的不知道这是什么意思，因为我将DAG属性放在PythonOperator中
import json
import decimal
import airflow
from airflow import DAG
from airflow.
浏览 3提问于2019-06-22得票数 5
回答已采纳
1回答
有没有办法让Alex宏在一个源文件中定义，并在其他源文件中使用？在我的例子中，我有$LowerCaseLetter和$UpperCaseLetter的定义(除了e和O之外，所有这些都是字母，因为它们在我的代码中有特殊的作用)。如何从其他.x文件引用这些宏？
浏览 2提问于2013-12-29得票数 1
我有一个恼人的问题在气流中，不断排队的许多任务在UI和为了保持他们的运行，我必须重新启动调度程序和工人。我的气流配置使用CeleryExecutor，在Reddis的帮助下在2名工人中运行。
我看了一下工人的原木，它给我看了这个：
Feb 05 06:53:37 ip-172-31-46-75 airflow[3656]: airflow.exceptions.AirflowException: dag_id could not be found: dc2_phd_nw_5225_processing. Either the dag did not exist or it failed to
浏览 1提问于2018-02-05得票数 1
我想运行一个简单的Dag "test_update_bq"，但是当我转到localhost时，我看到了这个：DAG "test_update_bq" seems to be missing。当我运行"airflow initdb“时没有错误，而且当我运行测试airflow test test_update_bq update_table_sql 2015-06-01时，它成功地完成了，并且在BQ中更新了表格。Dag： from airflow import DAG
from airflow.contrib.operators.bigquery_oper
浏览 55提问于2019-10-10得票数 0
回答已采纳
本质上，我想在另一个短代码中的某个预定点使用一个短代码。我的原始短代码正在抓取一大块文本，我想在某个时候插入下一个短代码，以便进行引号。
我唯一能想到的方法是使用javascript来解析页面加载的特定字符的原始短代码，然后插入短代码。
这个是可能的吗？
浏览 4提问于2015-08-18得票数 0
回答已采纳
有没有办法在Airflow中制作一个用户定义的宏，它本身是从其他宏计算出来的？ from airflow import DAG
from airflow.operators.bash_operator import BashOperator
dag = DAG(
'simple',
schedule_interval='0 21 * * *',
user_defined_macros={
'next_execution_date': '{{ dag.following_schedule(exec
浏览 77提问于2017-07-01得票数 29
回答已采纳
我正在尝试启动$ airflow websever (在新安装的实例上)，但是web服务器没有启动(浏览器状态为：This site can’t be reached)。
在终端中，我收到了以下错误消息
运行Gunicorn服务器时：
工人:4同步
主持人: 0.0.0.0:8080
超时:120个日志文件：
错误:无法导入名称“模型”
下面是我按照所采取的步骤：
刚在新鲜虚拟主机(py3.6)中安装了pip install apache-airflow
设置AIRFLOW_HOME env变量：export AIRFLOW_HOME=$(pwd)
初始化气流数据库。ai
浏览 0提问于2018-11-04得票数 1
1回答
我安装了气流，使用对接-合成和运行db init命令。我正在尝试创建一个使用DockerOperator执行某些脚本的DAG。在我的DockerOperator中，脚本试图读取气流变量并使用BaseHook获取连接。但是，我的DockerOperator中的脚本似乎连接到(空的) sqlalchemy数据库，而不是通过UI设置填充连接和变量的初始化postgres数据库。
是否有一种方法可以将DockerOperator上下文提供给包含通过UI设置的连接和变量的气流数据库？
我的气流DAG
from datetime import datetime
from json import dumps
浏览 6提问于2022-06-02得票数 1
回答已采纳
1回答
我有一个在成功和失败事件中执行动作和发送通知电子邮件的airflow作业，下面是我使用的代码。
#from builtins import range
from datetime import timedelta
from airflow.models import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.utils.dates import days_ago
from airflow.operators.email_operator import EmailOperator
from
浏览 2提问于2020-10-24得票数 1
我在我的sql_test.py中写了一些错误，并运行了python sql_test.py，错误是‘没有模块名为xxx'，而在web中，它显示了一个红色错误的DAG。然后我运行airflow list_dags，同样的错误再次发生，.This很奇怪，我不知道发生了什么。我试图运行airflow delete_dags sql_test，但是没有这样的id。我如何才能：
消除web-ui中的衰退
把sql_test从list_dags中解救出来
浏览 1提问于2019-07-26得票数 1
回答已采纳
我有一个pyspark脚本，它现在工作得很好，我想做的是，我想为每一分钟安排该作业，为此，我使用了Apache Airflow，我为airflow创建了一个.py文件，如下所示： from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta
import os
from builtins import range
import airflow
from airflow.models import DAG
from
浏览 24提问于2019-04-08得票数 0
是否可以在hiveconf变量的名称中使用点？
中的所有示例都显示简单的变量名，如a。
如果是：
如何在HQL脚本中引用它？select ${hiveconf:airflow.ctx.dag.dag_id} as dag_id;会产生语法错误(而${hiveconf:abcd}是可以的)。
If no:
为什么或要将变量传递给像这样的单元脚本？难道作者不知道不可能引用这些变量吗？
hive -hiveconf airflow.ctx.dag.dag_id=video-plays-adverts -f test-hiveconf.hql
谢谢!
浏览 8提问于2017-03-29得票数 0
我正在从Composer 1/Airflow 1实例移植一些DAG，这些实例最初是从独立的气流1.0集群中移过来的，在文件的开头(导入之后，但在我创建DAG之前)，用代码加载特定的配置文件，如下所示：
with open(SELLER_CONFIG_FILE, "r", encoding="utf8") as config_file:
SELLER_CONFIG_FILE存储在dags/config/__init__.py中，如下所示：
SELLER_CONFIG_FILE = os.getenv(
"FORKLIFT__SELLER_CONFIG_
浏览 5提问于2022-04-11得票数 0
1回答
我有一个Git存储库，其中包含airflow目录中的气流数据集。除了一个气流安装目录外，我还有一个存储库的克隆。Git中的airflow目录由AIRFLOW_HOME配置变量指向。
我希望允许从存储库中列出在airflow文件夹之外的模块进行导入(请参见下面的结构)。
<repo root>
|_airflow
|_dags
|_dag.py
|_module1
|_module2
|_...
因此，在dag.py中，我可以做到：
from module1 import Module1
目前，如果没有，这似乎是不可能的，比如显式
浏览 0提问于2019-08-27得票数 1
回答已采纳
在这个应答的帮助下，我正在执行一个python文件。
我使用PythonOperator，并试图将执行日期作为传递给脚本的参数。
我相信我可以通过kwargs的“执行日期”来访问它。
下面是失败的
DAG.py
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta
import sys
import os
sys.path.append(os.path.abspath("/home/gls
浏览 1提问于2018-04-30得票数 18
回答已采纳
2回答
是否可以通过UI将参数传递给Airflow的作业？
AFAIK，DAG中的'params‘参数是在python代码中定义的，因此不能在运行时更改。
浏览 6提问于2017-11-21得票数 18
回答已采纳
2回答
在Composer中，我目前需要用于我的气流实例的Airflow db连接凭证。
我在气流连接界面上看到的都是airflow_db mysql airflow-sqlproxy-service。
我想通过DataGrip连接到它。
另一件事是，如果我想更改[core] sql_alchemy_conn覆盖环境变量，那么当我在Composer环境中将它添加到env变量时，该如何做呢？
浏览 0提问于2018-12-05得票数 5
回答已采纳
合并gitlab代码后，触发了airflow dag，如何获取合并后的gitlab的commit_id和分支信息
浏览 16提问于2021-08-10得票数 0
我在我的计算机上本地运行标准的对接-撰写文件，所有的默认设置来自气流:2.1.4，postgres:13，redis:最新。当我有调度程序的一个实例时，一切都按预期的方式工作，但是当我添加调度程序的另一个实例时，我开始得到锁定问题。
postgres_1 | STATEMENT: SELECT slot_pool.pool AS slot_pool_pool, slot_pool.slots AS slot_pool_slots FROM slot_pool FOR UPDATE NOWAIT
我的相关停靠-撰写文件是
&airflow-common
environment:
浏览 3提问于2021-10-04得票数 1
回答已采纳
我有来自不同来源的日志，日志的格式是
[2018-11-20 11:27:41,187] {base_task.py:98} INFO - Subtask: [2018-11-20 11:27:41,186] {child_task.py:355} INFO - Inside poll job status
[2018-11-20 11:27:41,187] {base_task.py:98} INFO - Subtask: [2018-11-20 11:27:41,186] {child_task.py:357} DEBUG - Poll time out has been set to:
浏览 3提问于2018-11-29得票数 1
我尝试创建我的气流服务。当我分别运行三个dockers时(没有docker-compose)，一切都正常，但是当我尝试使用docker-compose做同样的事情时，我得到了错误。好像气流看不到数据库。
docker-compose.yml
version: '2'
services:
mysql:
image: "someregisty/mysql"
environment:
- MYSQL_ROOT_PASSWORD=somepassword
redis:
image: "someregisty/red
浏览 0提问于2017-09-28得票数 7
回答已采纳
我有一个气流DAG，我需要从气流上下文中获得DAG触发的参数。
以前，我有在DAG步骤中获取这些参数的代码(我使用的是气流2中的Taskflow API ) --类似于这样：
from typing import Dict, Any, List
from airflow.decorators import dag, task
from airflow.operators.python import get_current_context
from airflow.utils.dates import days_ago
default_args = {"owner": "
浏览 5提问于2021-10-21得票数 3
回答已采纳
我是第一次接触气流。我是通过pip install apache-airflow安装的。当我在终端中运行命令airflow initdb时，我得到了下面的错误。我在安装过程中哪里出了问题，我该如何解决这个问题？
aamir@aamir-Inspiron-3542:~$ airflow initdb
[2019-03-30 18:32:27,309] {__init__.py:51} INFO - Using executor SequentialExecutor
DB: sqlite:////home/aamir/airflow/airflow.db
[2019-03-30 18:32:31,
浏览 0提问于2019-03-30得票数 1
1回答
我有我的气流项目，结构如下
airflow
|
|----dags
| |----dag.py
|
|----dbt-redshift
|----models
|----model.sql
我在卷部分中包含了dbt-redshift目录，如
volumes:
-./dbt-redshift:/opt/airflow/dbt-redshift
我试图使用bash操作符在DAG中运行dbt
dbt_task = BashOperator(task_id='dbt'
浏览 14提问于2022-05-24得票数 0
回答已采纳
我有一个具有以下结构的气流项目
my_project
|
dags-custom-|custom_operator1.py
| |custom_operator2.py
| |custom_hook1.py
|
my_dag.py
通常情况下，如果我只有my_dag.py，我会这么做
cp my_dag.py ~/airflow/dags/
但是，在这种情况下，我不确定该如何将项目加载到气流DAGs列表中？
我应该做cp ~/my_project/ ~/airflow/dags/吗？
浏览 4提问于2022-04-15得票数 0
这是一个更高级的问题..。可以通过几个宏向下传递一个集合吗？例如，我有一个博客帖子部分： {% from "components/switchers/topCoupons.njk" import topBonuses %}
{{ topCoupons(
title = "Top Coupons",
blurb = "some body text content",
posts = collections.coupon
浏览 32提问于2021-08-10得票数 0
2回答
我做了一些搜索，没有找到一个“直接”回答这个问题的问题。
无论如何，这个问题的基本要点是，我想知道是什么“语言特性”或“语法”使一种语言成为构建解析器、语法突出显示等的主要难题？
这可能是主观的，但我在想，例如，解析一种语言(例如，Lisp )与其(func、parms等)的区别。结构，而不是包含所有模板、括号等的C++。
浏览 0提问于2010-05-13得票数 3
回答已采纳
1回答
我有一个文件定义了DAG对象：
dags/my_dag.py
from airflow import DAG
from datetime import datetime
default_args = {
'owner': 'pilota',
'depends_on_past': False,
'start_date': datetime(2019, 10, 1),
'email': ['some@email.com'],
'email_on_fail
浏览 4提问于2019-10-01得票数 1
回答已采纳
1回答
我目前正面临着解析嵌套宏的挑战。下面是我的DAG文件 from airflow import DAG
from airflow.utils.dates import days_ago
from datetime import timedelta
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator
from airflow.models import Variable
from apty.utils.date
浏览 12提问于2020-12-24得票数 1
我目前正在K8s上部署Apache Airflow (在EKS上)。我已经成功地部署了入口控制器(使用AWS Load Balancer Controller)和入口，并且我可以通过互联网访问入口。我的目标是能够访问主机和路径，而不是地址。 换句话说，现在要访问web服务器，我需要输入一个地址，如：internal-k8s-airflow-deployment-aws-region.elb.amazonaws.com。我的目标是使用类似于：meow.myimaginarywebsite.com/airflow的东西来访问它。 我想要做的是 我使用的是stable airflow Helm c
浏览 18提问于2021-01-26得票数 1
回答已采纳
在使用cloud-composer执行以下python脚本时，我在Airflow代码中的gcs2bq任务日志下获得了*** Task instance did not exist in the DB：
import datetime
import os
import csv
import pandas as pd
import pip
from airflow import models
#from airflow.contrib.operators import dataproc_operator
from airflow.operators.bash_operator import Bas
浏览 0提问于2018-11-19得票数 0
问题
我希望将值列表或任何值作为参数传递给自定义操作符，修改运算符中的值，然后通过{{ params }}宏访问sql模板中的值。
电流设置
以下是我的设置的相关部分，为了清晰起见，稍微设计了一下。
DAG的定义：
from airflow import DAG
from datetime import timedelta, datetime
from acme.operators.dwh_operators import ProcessDimensionOperator
default_args = {
'owner': 'airflow',
浏览 1提问于2019-02-27得票数 6
我们有一个python脚本所在的EC2实例，在同一个实例中，我们还安装了Airflow。通过给出python脚本的路径，我们能够使用Airflow DAGS执行这些python脚本。
现在，我现在的需求是使用Amazon managed Airflow执行这些python脚本。有人做过这样的实现吗？
浏览 3提问于2021-09-07得票数 0
下面是airflow DAG代码。无论是在本地托管airflow时，还是在cloud composer上，它都能完美运行。但是，无法在Composer UI中单击DAG本身。我找到了一个类似的问题，并尝试了中链接的被接受的答案。我的问题与此类似。
import airflow
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator
from airflow.ope
浏览 13提问于2019-03-28得票数 1
回答已采纳
1回答
我有一个简短的DAG，我需要将变量存储在Airflow中(Airflow -> Admin -> variables)。但是，当我们使用模板时，我得到了下面的错误。示例代码和错误显示如下：
from airflow import DAG
from airflow.models import Variable
from airflow.operators.python import PythonOperator
def display_variable():
my_var = Variable.get("my_var")
print('var
浏览 0提问于2021-10-05得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
