我正在尝试订阅Salesforce频道,因此能够从该频道中获取消息。但是问题是我正在接连收到消息,预期的接收方式是将大量消息发布到通道上。需要在订户中整体获取消息。
例如,如果我发布500条消息,则需要在订阅者上获得整条500条消息。但是我收到一个又一个消息。
我正在使用以下代码
async with client:
for topic in get_topics(system='salesforce'):
await client.subscribe(topic)
async for message in client:
messages = message
上面的代码在异步函数内部被调用
我不确定这是库中的错误还是我遵循的方法错误
请让我知道问题出在哪里。
我能够解决此问题,
它与库无关,非常棒。我能够实时获取消息。
问题出在我当前拥有的体系结构上,这导致了延迟。
谢谢大家的帮助。
我认为用这种方式回答不是很好,但是要回答,这样可能会使人抬起头来。在寻找此类错误时。
他们可以轻松地开始调试体系结构而不是库。