我正在嘗試將我的氣流日期從一位數轉換為兩位數。在我使用{{ execution_date.month }}月份的那一刻變成1但希望它變成01.
我試過{{ execution_date.month.strftime("%m") }}但得到錯誤:
int object'沒有屬性'strftime
uj5u.com熱心網友回復:
你可以做:
from datetime import datetime
from airflow.models import DAG
from airflow.operators.bash import BashOperator
with DAG(
dag_id="bash_example",
schedule_interval=None,
start_date=datetime(2022, 1, 19),
catchup=False
) as dag4:
BashOperator(task_id="task", bash_command="echo {{ execution_date.strftime('%m') }}")
或者
from datetime import datetime
from airflow.decorators import dag
from airflow.operators.bash import BashOperator
@dag(schedule_interval=None, start_date=datetime(2022, 1, 19), catchup=False)
def bash_example():
BashOperator(task_id="task", bash_command="echo {{ execution_date.strftime('%m') }}")
dag = bash_example()
渲染:

日志:

轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/420061.html
標籤:
下一篇:根據另一個表中的日期計算總和
