我正在使用 Cloud Pub/Sub 推送全天完成的事件生成的通知负载。我有另一个由调度程序在一天结束时触发的云功能，用于从发布/订阅中提取通知并发送电子邮件通知。
我想要为用户提供聚合通知的功能。因此，我想合并为特定用户生成的所有有效负载，以便按用户分组并发送通知。
我曾想过为每个用户进行单独的订阅，然后我会将订阅中的所有消息作为聚合的有效负载进行处理。但这似乎不是一个好的解决方案。
有没有办法根据键或属性合并发布/订阅消息？
您可以将事件和用户信息存储在 mongoDB 或 redis 中，并可以在一天结束时运行 cron 作业来合并数据并向用户发送通知。使用后删除数据。