r - 如何在 R 中订阅 GCP Pub/Sub 消息？

问题描述

我正在使用 Python 中的 Google Cloud Pub/Sub 库，https://github.com/googleapis/python-pubsub

在这里订阅 Pub/Sub 中的消息非常容易：

import os
from google.cloud import pubsub_v1

topic_name = 'projects/{project_id}/topics/{topic}'.format(
    project_id=os.getenv('GOOGLE_CLOUD_PROJECT'),
    topic='MY_TOPIC_NAME',  # Set this to something appropriate.
)

subscription_name = 'projects/{project_id}/subscriptions/{sub}'.format(
    project_id=os.getenv('GOOGLE_CLOUD_PROJECT'),
    sub='MY_SUBSCRIPTION_NAME',  # Set this to something appropriate.
)

def callback(message):
    print(message.data)
    message.ack()

with pubsub_v1.SubscriberClient() as subscriber:
    subscriber.create_subscription(
        name=subscription_name, topic=topic_name)
    future = subscriber.subscribe(subscription_name, callback)

R中是否有类似的库？似乎此功能分布在多个 R 库中，主要由 Mark Edmondson 编写。googleCloudRunner有这个功能cr_plumber_pubsub()，但这是在 CloudRun 中使用的。我想将此 R 代码集成到其他地方。

此任务有哪些可用选项？

标签： rgoogle-cloud-platformpublish-subscribe

鉴于这个问题是在几个月前提出的，我想 OP 现在可能已经解决了他的问题。

对于未来的读者，我想提一下googlePubsubR现在可以在 CRAN 上使用的事实，它涵盖了大多数 Pub/Sub 使用案例。

r - 如何在 R 中订阅 GCP Pub/Sub 消息？

问题描述

解决方案

推荐阅读