Google Bigquery API：如何将结果查询添加到表中？答案

【问题标题】：Google Bigquery API: How to add result query to Table?Google Bigquery API：如何将结果查询添加到表中？
【发布时间】：2016-06-21 09:04:38
【问题描述】：

我已经阅读了一些关于这个主题的介绍，但是这段代码没有运行。我在项目中创建了表“product_flat_index”，这个函数将查询结果添加到该表中。但它没有运行。

def insertValues(service):
    project_id = "598330041668"
    dataset_id = 'recommendation_001'
    table_id = 'product_flat_index'


    # [START run_query]

    query = ('SELECT sku, SUM(sales) AS sales, COUNT(sales) AS sales_frequency, SUM(views) AS views,'
          'SUM(carts) AS carts,  SUM(sales) / SUM(carts) AS sales_effective_rate,AVG(rating) AS rating,'
          'SUM(comments) AS comments '
          'FROM recommendation_001.user_input_product '
          'GROUP BY sku '
             )

    configuration = {
        "query": query,

    }
    body = {
        "configuration":
        {
            "query": configuration,
            "destinationTable": {
                "projectId": project_id,
                "datasetId": dataset_id,
                "tableId": table_id
            },
            "createDisposition": "CREATE_IF_NEEDED",
            "writeDisposition": "WRITE_APPEND",
        },

    }

    return service.jobs().insert(
        projectId=project_id,
        body=body
    ).execute()
    # [END run_query]

【问题讨论】：

标签： python google-bigquery bigdata

【解决方案1】：

您应该在查询配置对象中指定destinationTable、createDisposition, 和writeDisposition 属性，而不是顶级配置。它们是 configuration.query 的属性，而不是顶级配置。例如，here's the destinationTable property in our docs: note how it is configuration.query.destinationTable，而不是 configuration.destinationTable。您指定的其他字段的结构类似。

我认为这应该可行：

configuration = {
    "query": query,
    "destinationTable": {
        "projectId": project_id,
        "datasetId": dataset_id,
        "tableId": table_id
    },
    "createDisposition": "CREATE_IF_NEEDED",
    "writeDisposition": "WRITE_APPEND"
}
body = {
    "configuration":
    {
        "query": configuration
    }
}

如果您想自行调试，我建议您使用 jobs.list 或 jobs.get 查找作业详细信息，以查看您的配置详细信息是否已通过服务器。我怀疑你过去没有工作的工作也不会有destinationTable等的附加属性。

【讨论】：