如何将 {{ds}} 气流宏转换为 DATE 数据类型

如何解决如何将 {{ds}} 气流宏转换为 DATE 数据类型

df['date'] = {{ds}}

在这个数据框中，我想要存储一个 DATE 类型的值，但我得到的只是一个字符串数据类型。

解决方法

您不能在运算符范围之外使用宏。宏作为操作符执行的一部分呈现，否则它只是一个纯文本字符串。 {{ ds }} 只能用于运算符的模板化字段。在您的示例中，很明显您希望在可调用的 python 中而不是在模板化字段中获取 ds 的值，因此您可以获得以下值：

def func(**kwargs):
    execution_date = kwargs['execution_date']
    df = pd.DataFrame()
    df['execution_date'] = execution_date
    #If you want also to convert the column to datetime you can add
    df['execution_date'] = pd.to_datetime(df['execution_date'])
    print(df)

op = PythonOperator(
    task_id='example',python_callable=func,provide_context=True,dag=dag
)