0

我在谷歌存储云中有一个存储桶。此外，我有一个存储功能，每次在此存储桶上创建新文件/文件夹时都会触发该功能。此功能的想法是在 google PubSub 上发布在“monitoring”文件夹下创建的文件。因此，一旦有新文件，它将被触发，但如果文件是在上述文件夹下创建的，则仅将消息发送到 PubSub。此外，我有一个订阅 PubSub 的 Java 应用程序接收此消息。它能够毫无问题地接收消息，但是当我关闭应用程序并再次午餐时，几分钟后，之前传递的消息又来了。我检查了日志，看看是否触发了存储功能，但事实并非如此，似乎没有再次向 PubSub 发送消息。所有消息均已确认，PubSub 为空。我是否缺少与存储功能或 PubSub 相关的内容？

这是我的存储函数定义：

const {PubSub} = require('@google-cloud/pubsub');
const topicName = 'test-topic-1';
const monitoringFolder = 'monitoring/';

exports.handler = (event, context) => {
    console.log(event);
    if (isMonitoringFolder(event.name)) {
        publishEvent(event);
    }
};

const publishEvent = (event) => {
    const pubSub = new PubSub();
    const payload = {
        bucket: event.bucket,
        filePath: event.name,
        timeCreated: event.timeCreated
    };
    const data = Buffer.from(JSON.stringify(payload));
    pubSub
        .topic(topicName)
        .publish(data)
        .then(id => console.log(`${payload.filePath} was added to pubSub with id: ${id}`))
        .catch(err => console.log(err));
};

const isMonitoringFolder = filePath => filePath.search(monitoringFolder) != -1

我真的很感激任何建议

4

1 回答 1

1

Pubsub 不保证消息的单次出现

Google Cloud Pubsub 具有至少一次交付政策。对于每个订阅，这至少会传递每个已发布的消息一次。但它可以交付多次

https://cloud.google.com/pubsub/docs/subscriber

于 2020-04-23T21:55:13.880 回答