如何在射流流上进行请求?
我为 https://github.com/hnakamur/nats-stream-example/tree/2c834d7d967d967f024348fbaa478ee18e9749431ba 。 作为实验的下一步,我试图为” norefl…
群集nats causit“ bytes slice”为空。错误
我正在以集群模式运行NAT: docker run -d --network host nats -p 4222 -cluster nats://127.0.0.1:6222 docker run -d --network host nats -p 4333…
NATS/JETSTREAM:命令命令约定命令'主题
我一直在与NATS/Jetstream合作,现在以及CQRS/事件采购项目中有一段时间。最近,在我看来,我没有遵循任何用于命令的主题名称的命名约定(事件几乎涵…
attributeError:模块' nats'没有属性'连接'
https://nats-io.github.io/nats.py/modules。 html Traceback (most recent call last): File "c:\Users\lb\nats.py", line 22, in asyncio.run(mai…
使用Apollo服务器中的PubSub将消息发送到第三方工具
我还有另一项后端服务,该服务正在使用Nats PubSub订阅特定主题。我想通过在阿波罗服务器中发表特定解析器的消息来与该服务进行通信。推荐的方法是什…
Docker容器无法相互连接 - 连接拒绝
我有一个由Docker组成的简单应用程序。它由一个简单的前端(使用NextJS构建),GraphQl API(使用Nestjs构建)和微服务(使用Nestjs构建)组成。 架构…
nats jetstream在调用stream_info(stream_name)时正在计时。
引起错误 nats.errors.timeouterror:nats:超时 if self.nc.is_connected: log.info(f"NATS client successfully connected to {SERVERS}") # Create…
有没有办法查看NATS消息?
我正在尝试在NATS集群中查看某个主题的消息。 我的Google搜索导致 https://github.com/kaliaco/kalicico/nats-nats-contreaming-console 和 https://…
您如何正确处理python中异步代码的异常?
Main.py import asyncio import signal from nats.aio.client import Client as NATS from client.nats_client import NATSClient from factory.logge…
NATS JetStream 可以在不同的 NATS 服务器上部分复制流吗?
我的服务器 A 带有 NATS Jet Stream。我希望在服务器 B 和服务器 C(NATS 流)上复制 NATS 流的某些部分,并且互斥。…
是否可以将 Nats JetStream 与 EncodedConn 一起使用?
我正在一个 go 项目中将 Nats core 转换为 Nats jetstream。我正在使用 nats.go,我注意到 EncodedConn 请求在传输程序文件中随处使用。但 EncodedCon…
grpc服务器发送数据到队列,Nats io
我有一种情况,我需要将 grpc 服务器(流)数据的数据发布到 Nats io 发布者,这个 nats io 将被许多客户端订阅 Grpc Server ----->Nats Io -->Client…
AWS 上的间歇性 NATS 连接失败并超时
我们有一个 clojure 应用程序,它使用 NATS 和 NATS Java 库来支持集群。这全部部署在AWS EC2实例上。 从昨晚开始,我们发现应用程序和 NATS 实例之间…
- 共 1 页
- 1