使用云功能在Google Cloud Pub / Sub上发布需要3分钟-Node.js

debugcn 发表于 Dev

ike1504

我正在执行的功能将在接收到Webhook后发布事件的类型。它可以正常工作，但是会在该功能启动后3分钟左右发布消息。这么长的停顿来自于const {PubSub} = require('@google-cloud/pubsub')我该如何使其更快？谢谢！

源代码：

exports.Challenge = (req,res) => {
    var type = req.body['event']['type']   
    console.log(type)                       
    console.log("start pubsub msg function")
    msgpubsub(type)
    console.log("end pubsub msg function")
}

function msgpubsub(_type){
    const topicName = "NAME_OF_TOPIC"
    console.log(`publishing message to topic: ${topicName}`)

    console.log("start require('@google-cloud/pubsub")
    const {PubSub} = require('@google-cloud/pubsub')
    console.log("end require(@google-cloud/pubsub)")

    console.log("start new pubsub")
    const pubSubClient = new PubSub('ID');
    console.log("end newpubsub")
    
    const messageBuffer = Buffer.from(_type)
    console.log("message buffer : " + messageBuffer)

    try{
        pubSubClient.topic(topicName).publish(messageBuffer)
    } catch(err){
        console.error(err)
    }

日志

卡玛勒·阿博尔·霍恩（Kamal Aboul-Hosn）

最好一次创建客户端，然后在收到事件时使用客户端发布消息。现在，您正在为每个事件创建一个全新的客户，这很昂贵。

const topicName = "NAME_OF_TOPIC"
const {PubSub} = require('@google-cloud/pubsub')
const pubSubClient = new PubSub('ID');
const topicPublisher = pubSubClient.topic(topicName);

exports.Challenge = (req,res) => {
    var type = req.body['event']['type']   
    console.log(type)                       
    console.log("start pubsub msg function")
    msgpubsub(type)
    console.log("end pubsub msg function")
}

function msgpubsub(_type){    
    const messageBuffer = Buffer.from(_type)
    console.log("message buffer : " + messageBuffer)

    try {
        var publishFuture = topicPublisher.publish(messageBuffer);
        publishFuture.get();
    } catch(err){
        console.error(err)
    }
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。