打印查看BigQuery的查询结果

Question

我有一个函数内部的BigQuery查询，如下所示：

def get_data_from_bigquery(): 
    """query bigquery to get data to import to PSQL""" 
    app_id = get_app_id() 
    bq = bigquery.Client(project=app_id) 
    query = """SELECT * FROM `Backup.Prod_UserUserMetadata`""" 
    query_job = bq.query(query) 
    data = query_job.result() 
    rows = list(data) 
    print(rows) 
    return rows 

我有我的路线如下：

@app.route('/azure-import-data') 
def print_data(): 
    return 'This is the data:\n \n' 

功能get_data_from_bigquery()被称为在我的下面的类内get()功能：

class AzureImportProcess(Resource): 
    def get(self): 
     get_data_from_bigquery() 
... 
api.add_resource(AzureImportProcess, '/azure-import-data') 

的print(rows)函数似乎不起作用，因为它没有被打印在云控制台或浏览器中。有没有其他方法可以打印数据以查看它的格式？

Answer 1

首先，您不需要get_data_from_bigquery函数中的print声明。其次，get函数需要有一个return声明才能显示。

编辑函数定义如下：

def get_data_from_bigquery(): 
    """query bigquery to get data to import to PSQL""" 
    app_id = get_app_id() 
    bq = bigquery.Client(project=app_id) 
    query = """SELECT * FROM `Backup.Prod_UserUserMetadata`""" 
    query_job = bq.query(query) 
    data = query_job.result() 
    rows = list(data) 
    return rows 

编辑Resource类的定义如下：

class AzureImportProcess(Resource): 
    def get(self): 
     bq_data = get_data_from_bigquery() 
     return 'This is the data:\n \n{}'.format(bq_data) 

现在，您可以将您的资源添加到API对象：

api.add_resource(AzureImportProcess, '/azure-import-data') 

您不需要定义print_data函数，除非你正在处理更复杂的API。

我希望这会有所帮助。