Node.js 如何在没有云功能的情况下使用 Google PubSub

发布于09月30日

如何在不使用云功能的情况下使用Google PubSub检索计费更新？我目前正在使用下面的代码，但它显示onPublish不存在:

const { PubSub } = require('@google-cloud/pubsub');
const pubsub = new PubSub('MyProjectID');



handleServerEvent = pubsub.topic(GOOGLE_PLAY_PUBSUB_BILLING_TOPIC)
  .onPublish(async (message) => {

  })

TypeError:pubsub.topic(...).onPublish不是函数

我正在使用Node.js，并希望对发布在主题上的事件做出react .

推荐答案

onPublish()方法是云函数API的一部分.您需要使用createSubscription()来获取Subscription对象，然后使用它来侦听新消息.try 以下操作:

const listenToTopic = async (topicName: string) => {
  const [sub] = await pubsub
    .topic(topicName)
    .createSubscription("subscriptionName");

  sub.on("message", (message) => {
    message.ack();
    console.log(`Received message: ${message}`);  
  });
};

// start listener
listenToTopic(GOOGLE_PLAY_PUBSUB_BILLING_TOPIC)

创建订阅后，您需要将createSubscription("subscriptionName")更改为subscription("subscriptionName")以监听传入的消息，因为订阅已经创建