熊猫-从GCP进口数据

Question

我正在尝试从GCP导入数据，但是下面有错误。

代码：

import pandas as pd
from pandas.io import gbq
DF = """SELECT * FROM `im-test-209122.PPM_UAT.SAP_PS_CONSOLIDATED` LIMIT 1000"""
DF = gbq.read_gbq(DF,project_id="im-test-209122")
DF.head(3)

错误：

ConnectionError：(“连接中止”，ConnectionResetError(10054，“现有连接被远程主机强制关闭”，无，10054，无))

Answer 1

您向BigQuery库提供了pandas_gbq身份验证吗？我使用一个服务帐户来提供这个链接中的信息之后的身份验证。您必须下载json密钥并使用google.oauth2库在代码中提供文件。使用下面的代码，我可以从我的BigQuery项目中查询数据。

    from pandas.io import gbq
    from google.oauth2 import service_account

    sql = "SELECT * FROM PROJECT_ID.DATASET.TABLE"

    credentials = service_account.Credentials.from_service_account_file('path-to-key-file.json')
    df = gbq.read_gbq(sql, project_id="PROJECT_ID", credentials=credentials)

    df.info()
    print(df)

我不确定这是否面临着你所面临的问题，因为我无法得到与你相同的错误，但我希望它会有所帮助。