时间戳

首页 > 解决方案 > 如何从 Airflow 中的 BigQuery 获取查询结果，并将其附加到自动发送给我的电子邮件中

google-bigquery - 如何从 Airflow 中的 BigQuery 获取查询结果，并将其附加到自动发送给我的电子邮件中

问题描述

我想使用动态时间{{ macros.ds_add(ds, 0) }}，所以pandas_gbq.read_gbq不起作用。

我也使用了get_pandas_dfof BigQueryHook，它显示'BigQueryPandasConnector'object has no attribute 'http_error'，文档说我需要覆盖DbApiHook方法，但我不知道如何。

这个问题有什么解决方案吗？感谢您的帮助，伙计们。

标签： google-bigqueryairflow

解决方案

使用BigQueryGetDataOperator. 下面是一个例子：

示例：:: 

    get_data = BigQueryGetDataOperator(
        task_id='get_data_from_bq',
        dataset_id='test_dataset',
        table_id='Transaction_partitions',
        max_results='100',
        selected_fields='DATE',
        bigquery_conn_id='airflow-service-account'
    )

官方文档：https ://airflow.readthedocs.io/en/stable/integration.html#bigquerygetdataoperator

推荐阅读