如何从 Firebase Cloud Function 在 Google Pub/Sub 中发布消息？

Question

我写了一个函数来接收一个 http 请求并发送一封电子邮件。但是，我想收到一个 http 请求并发送一个 pub 消息。问题是文档不清楚。我该怎么做？

这是我的实际代码。

exports.weeklyEmail = functions.https.onRequest((req,res) => {
const email = '****@gmail.com'

console.log('Sending e-mail')

const mailOptions = {
    to: email,
    from: '****@alunos.utfpr.edu.br',
    subject: 'Teste',
    text: 'Conteudo do email '
}   

mailTransport.sendMail(mailOptions).then(
    () => {         
        res.send('Email sent')
    }
).catch(error => {
    res.send(error)
})
})

Answer 1

需要导入pub-sub库const {PubSub} = require('@google-cloud/pubsub')，发起客户端，发布消息。
文档：

• https://cloud.google.com/pubsub/docs/publisher#publish-messages-to-a-topic
• https://cloud.google.com/functions/docs/calling/pubsub

---

不过，另一种方法是在firestore writes 上触发后台功能。

每当您在集合 (pubsub) 中创建文档时，您的 bg 函数都会在文档写入时被调用：

exports.myTriggerFunction = functions.firestore
  .document('pubsub/{docId}')
  .onWrite((change, context) => { /* ... */ });

而且，它不仅限于onCreate：

Event Type  Trigger
onCreate    Triggered when a document is written to for the first time.
onUpdate    Triggered when a document already exists and has any value changed.
onDelete    Triggered when a document with data is deleted.
onWrite     Triggered when onCreate, onUpdate or onDelete is triggered.

Answer 2

据我了解，您希望通过 Firebase Cloud Functions 实现向 Pub/Sub 发送消息。

您可以轻松地使用Node.js Pub/Sub client library，它具有已定义的功能，例如publish。

或者，如果您愿意，您可以构建自己的客户端，直接调用REST API for Google Cloud Pub/Sub。如果它更适合您的需求，还有一个 RPC reference。

---

你不需要

broker 的主机、端口、id、密码等信息

作为提到的客户端，否则您的 REST API 请求将需要 authentication 。