方法是什么?"/>
在nodejs中创建大量Google pubsub订阅者的推荐方法是什么?
我需要听大约40个订阅(在未来几天内,这个数量将增加)。
[如果只有一个订阅,那么我将执行以下操作,
const subName = 'mysubscription'
const pubSubClient = new PubSub()
const startVidsubscription = pubSubClient.subscription(subName)
startVidsubscription.on('message', messageHandler)
const messageHandler = async(message) => {
// do stuff
}
但是,当我有数十个订阅时,我将无法执行此操作。因此,我正在尝试以下操作:
// the name is the name of each subscription and the variable is the variable name in which I will be holding the subscription object.
var subscriptionDetails = [
{'name': 'M10057-sub-cam1Api', 'variable': 'M10057Subscription'},
{'name': 'M10058-sub-cam1Api', 'variable': 'M10058Subscription'},
{'name': 'M10059-sub-cam1Api', 'variable': 'M10059Subscription'},
]
for(const subscription of subscriptionDetails){
var subscription.variable = pubSubClient.subscription(subscription.name)
subscription.variable.on('message', messageHandler)
}
但是这给了我类似Unexpected token, expected ;
的错误。
任何人都请让我知道在nodejs中收听大量订阅的推荐方法
回答如下:您的一般方法应该有效。将预订对象分配给已定义为字符串的subscription.variable
可能会遇到问题。
类似以下内容将起作用:
const {PubSub} = require('@google-cloud/pubsub');
const pubSubClient = new PubSub();
const messageHandler = async(message) => {
// ... handle message ...
};
var subscriptionDetails = [
{'name': 'M10057-sub-cam1Api'},
{'name': 'M10058-sub-cam1Api'},
{'name': 'M10059-sub-cam1Api'},
];
for (const subscription of subscriptionDetails) {
subscription.variable = pubSubClient.subscription(subscription.name);
subscription.variable.on('message', messageHandler);
}
然后您可以使用variable
中的subscriptionDetails
字段引用订阅对象。
如果要通过名称'M10057Subscription'引用订阅对象,则可以创建订阅对象的映射:
var subscriptionDetails = [
{'name': 'M10057-sub-cam1Api', 'variable': 'M10057Subscription'},
{'name': 'M10058-sub-cam1Api', 'variable': 'M10058Subscription'},
{'name': 'M10059-sub-cam1Api', 'variable': 'M10059Subscription'},
];
var subscriptionObjects = {};
for (const subscription of subscriptionDetails) {
subscriptionObjects[subscription.variable] = pubSubClient.subscription(subscription.name);
subscriptionObjects[subscription.variable].on('message', messageHandler);
}
// subscriptionObjects['M10057Subscription'] is a subscription object
更多推荐
在nodejs中创建大量Google pubsub订阅者的推荐方法是什么?
发布评论