可以使用Airflow的BigQueryHook
来获取数据插入到BigQuery表中的当前日期,代码示例如下:
from airflow.hooks.bigquery_hook import BigQueryHook
from datetime import datetime
bq_hook = BigQueryHook()
now = datetime.now().strftime("%Y-%m-%d")
# 使用 SQL 查询获取插入时间
query = f"""
SELECT TIMESTAMP('{now}')
"""
# 执行 SQL 查询并获取结果
conn = bq_hook.get_conn()
cursor = conn.cursor()
cursor.execute(query)
result = cursor.fetchone()
# 打印结果的第一行以获取当前日期
current_date = result[0].date()
print(current_date)
这将执行一个SQL查询,该查询返回当前日期的时间戳。从时间戳中提取日期并打印出来。
注意:如果你的表中的数据具有自己的时间戳字段,可能更好的方法是查询此字段而不是使用当前日期。