{{ my_variable | int }}
将字符串变量转换为整数或 {{ my_variable | float }}
将字符串变量转换为浮点数。{{ str(int(my_variable)) }}
将字符串变量转换为整数并再次转换回字符串。
示例:from datetime import timedelta
from airflow import DAG
from airflow.models import Variable
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2021, 1, 1),
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5)
}
dag = DAG(
'example_dag',
default_args=default_args,
schedule_interval=timedelta(days=1)
)
my_variable = Variable.get('my_variable')
with dag:
task1 = BashOperator(
task_id='task1',
bash_command='echo {{ my_variable | int }}', # 强制将变量转换为整数
)
task2 = BashOperator(
task_id='task2',
bash_command='echo {{ str(int(my_variable)) }}', # 使用Python表达式
)
task1 >> task2
上一篇:Airflow中的计划间隔