publish-subscribe 相关问题

发布/订阅是一种消息模式,其中消息的发送者(发布者)不对要直接发送到特定接收者(订阅者)的消息进行编程。相反,已发布的消息被表征为频道,而不知道可能存在的订户(如果有的话)。

如何使用Azure Pub Sub发送图像和二进制文档?支持吗?

如何使用Azure Pub Sub发送图像和二进制文档?是否支持或仅支持文本? 尝试将图像和文档发送到 azure pub sub。有什么限制吗?任何我们的例子...

回答 1 投票 0

使用不同服务帐号时,云函数无法调用另一个云函数

我有2个不同的云功能。当前设置如下: 云调度器触发功能A 函数 A 使用 pub/sub 在脚本末尾触发函数 B 两种云功能...

回答 1 投票 0

Dapr - Quarkus 运行/构建错误 java.lang.ClassNotFoundException:javax.ws.rs.ext.MessageBodyReader

我正在尝试使用 Dapr & Quarkus & Gradle 构建一个非常简单的 Pub/Sub 演示,但我面临以下错误: [错误]:构建步骤 io.quarkiverse.dapr.deployment.DaprProcessor#

回答 1 投票 0

Redis 和 Kafka 的区别

Redis 可以像 Kafka 一样用作实时发布-订阅。 我很困惑何时使用哪一个。 任何用例都会有很大帮助。

回答 3 投票 0

实时消息删除订阅返回空

我目前正在致力于在 GraphQL 应用程序中实现实时消息删除。我已经设置了必要的突变和订阅解析器,但我遇到了一个问题,其中

回答 1 投票 0

当事件从不同源发布到 GCP pubsub 主题并由单个接收者使用时,属性和消息交换

假设我们有 3 个应用程序 App1、App2、App3,这 3 个应用程序都会发布事件,其中事件是 GCP pubsub 主题的消息和属性。例如App1发布消息m1,属性为a1 和...

回答 1 投票 0

如何配置 Google Workspace 提醒中心以向 PubSub 主题发布提醒?

我正在构建一个通知系统,当员工采取触发 DLP 规则的操作时,该系统将通知处于松弛状态的员工。 我想要达到的理想流程是: 员工采取行动 > 规则三...

回答 2 投票 0

如何仅从反应流中发出累积和?

我有一个用例,其中流应该仅在累积“总和”等于或超过给定值 n 时发出。让我们以 n = 5 的六个整数为例。 +---+------+---------+ |...

回答 3 投票 0

Redis通道中PUB/SUB时消息的大小限制是多少

我目前正在我的一个项目中实现redis PUB/SUB,这引起了我的一个担忧,在Redis通道中PUB/SUB时消息的大小限制是多少。限制是否等于可用...

回答 2 投票 0

多个用户连接到一个包含用户特定数据的 Pub Sub 主题是否正常?

我是 gcloud pub sub 的新手,我想实现它,以便我可以从服务器到客户端自托管节点 JS 服务器进行通信,而用户不必从其公开公开 Web 服务器

回答 1 投票 0

push/pop 真的不能作为云服务使用吗?

我们正在寻找一种消息队列系统,确保根据消息的行号顺序处理消息。 这似乎是计算的基础部分 - 但我们似乎无法......

回答 2 投票 0

如何将姿态、角速度、线加速度这3个ROS2主题合并到一个IMU主题中?

我有 3 个主题已在 ROS2 中发布。即我的机器人发布了这3个主题:姿态、线加速度和角速度。 /robot/attitude 是 Geometry_msgs/msg/

回答 0 投票 0

flink-connector-gcp-pubsub 的正确使用方法是什么

不知道DeserializationSchema参数应该填什么 谁能帮我? PubSubSource source = PubSubSource.newBuilder() .

回答 1 投票 0

android hive MQ客户端如何订阅多个mqtt主题

我似乎找不到使用 .topicfilter("topic/test) 订阅多个主题的方法。有人知道如何让它订阅主题列表吗?

回答 0 投票 0

Debezium 服务器到 PubSub:删除操作破坏了应用程序

我想将有关源数据库(postgres 和 sql-server)更改的通知发送到 pubsub,以便稍后将数据存储在 bigquery 中。到目前为止,一切都很好。我决定看看 debezium 服务器...

回答 1 投票 0

并发订阅pubsub导致致命错误:concurrent map writes

使用以下设置在 Go 中订阅 GCP pubsub sub.ReceiveSettings.Synchronous = false sub.ReceiveSettings.NumGoroutines = 10 sub.ReceiveSettings.MaxOutstandingMessages = 100 做...

回答 0 投票 0

如何在DDS系统中同步多个监听器和发布器

我希望让这个问题不特定于一个特定的框架。相反,我想建立一种使用 C++ 在发布/订阅系统中同步消息的机制?那将如何工作? T...

回答 0 投票 0

是否有相当于 AWS SQS 的 GCP?

我很好奇了解 GCP 的 PubSub 的实现。虽然 Pubsub 似乎指向遵循 Publish-Subscribe 设计模式,但它似乎更接近 AWS 的 SQS(队列)而不是 AWS SNS(那个......

回答 2 投票 0

esp32 cam PubSubClient 不发布 base64 编码的消息

我正在尝试使用 esp32 cam 捕获图像并将其发送到 AWS IoT Core 以在云中对该图像进行进一步处理。 图像被捕获并编码为 base64 但是当我调用

回答 0 投票 0

Terraform 无法更新订阅

我有 terraform 脚本定义一个 pubsub 订阅推送数据到 bigquery 如下: 资源“google_pubsub_subscription”“我的订阅”{ 名字=“我的-

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.