如何使用 Flask 检查 BigQuery 的特定列中是否存在数据？

Question

我一直在使用 Flask 制作 api，它接收带有参数（luid）的 HTTP 请求，获取参数并将它们传递给 SQL 语句中的 Bigquery，如果 luid 的记录在 cv_date 列中有数据，则返回 True。但是，当我尝试使用实际存在于 BigQuery 表中但不存在于其中的 luid 向此 api 发送请求时，我从他们俩那里接受了 True 。如果它采用 BigQuery 中不存在的 luid 参数，我想让它返回 False 。似乎尝试和异常不能很好地工作。谁能给我个主意？？我很抱歉我糟糕的代码。如果缺少任何信息，请告诉我。非常感谢。

此外，我已经设置了 export GOOGLE_APPLICATION_CREDENTIALS = Json.file 并将 IAM 分配给此服务帐户。我通过 gcloud app logs tail -s test 成功将 SQL 发送到 BigQuery。

我提到的网站在下面https://blog.morizyun.com/python/library-bigquery-google-cloud.html Receive HTTP request with Variable, Query BQ and Return Response

/home/user/api_dev/main.py

from flask import Flask, request
from google.cloud import bigquery


app = Flask(__name__)


@app.route('/')
def get_request():
    # luid = request.args.get('luid') or ''
    client = bigquery.Client()
    query = """SELECT EXISTS(SELECT cv_date
FROM `test-266110.conversion_log.conversion_log_2020*`
WHERE luid = `test-266110.conversion_log.conversion_log_2020*`.luid limit 1000)"""

    try:
        query_job = client.query(query)
        is_exist = len(list(query_job.result())) >= 1
        return "True"
    except:
        return "False"


if __name__ == "__main__":
    app.run()

BigQuery 

luid | pgid | cv_date | orderid 
Uxxxx| 1111 | 2020-08-01| 2222　if this luid, it returns True 
Uxxxx| 2222 | 　　　　　|        if this luid, it returns False 

Answer 1

当您执行与数据库中的任何条目都不匹配的 SELECT 时，不会引发错误，因此您的 except: 不会被执行。仅当您的 try: 部分引发异常时，您的代码才会返回 False。

您的逻辑似乎是正确的：is_exist 应使用>= 运算符返回的True 或False 值进行初始化。你只需要返回那个值而不是总是返回True。此外，您可以保留except:，并假设如果在过程中抛出异常，则没有条目与select语句匹配：

[...]
    try:
        query_job = client.query(query)
        is_exist = len(list(query_job.result())) >= 1
        return str(is_exist)
    except:
        return False
[...]