小编Joa*_*uim的帖子

我没有在kafka上工作过多,但想在GCE中构建数据管道.所以我们想知道Kafka vs PUB/Sub.基本上我想知道如何在Kafka和Pub/sub中维护消息一致性,消息可用性,消息可靠性

谢谢

我正在使用 Google Cloud Functions 连接到 Google Bigquery 数据库并更新一些行。云函数是使用 Python 3 编写的。

每当我通过该函数运行更新 dml 时，我都需要帮助弄清楚如何获取结果消息或更新/更改的行数。有任何想法吗？

from google.cloud import bigquery

def my_update_function(context,data):

    BQ = bigquery.Client()
    query_job = BQ.query("Update table set etc...")
    rows = query_job.result()
    return (rows)

我知道行总是作为 _emptyrowiterator 对象返回。我可以通过什么方式获得结果或结果消息？文档说我必须从 bigquery 作业方法中获取它。但是好像想不通。