Airflow Bigquery Hook :如何在python变量中保存结果？

在Airflow中，可以使用BigQuery Hook来执行与Google BigQuery相关的任务。当需要将BigQuery查询的结果保存到Python变量中时，可以使用execute_get_first()方法。

以下是保存BigQuery查询结果到Python变量的示例代码：

from airflow.contrib.hooks.bigquery_hook import BigQueryHook

# 创建BigQuery Hook对象
bq_hook = BigQueryHook()

# 定义BigQuery查询语句
query = """
SELECT column_name
FROM dataset.table
WHERE condition
"""

# 执行查询并保存结果到变量
result = bq_hook.get_first(query)

# 打印结果
print(result)

在上述代码中，首先创建了一个BigQuery Hook对象。然后定义了一个BigQuery查询语句，并使用get_first()方法执行查询并将结果保存到变量result中。最后，可以通过打印result来查看查询结果。

请注意，上述代码仅为示例，实际使用时需要根据具体的查询语句和条件进行修改。

推荐的腾讯云相关产品和产品介绍链接地址：