无法从使用aiosfstream(用于Salesforce的Python库)订阅的频道批量接收消息

问题描述 投票:0回答:1

我正在尝试订阅Salesforce频道,因此能够从该频道中获取消息。但是问题是我正在接连收到消息,预期的接收方式是将大量消息发布到通道上。需要在订户中整体获取消息。

例如,如果我发布500条消息,则需要在订阅者上获得整条500条消息。但是我收到一个又一个消息。

我正在使用以下代码

async with  client:
    for topic in get_topics(system='salesforce'):
        await client.subscribe(topic)
    async for message in client:
        messages = message

上面的代码在异步函数内部被调用

我不确定这是库中的错误还是我遵循的方法错误

请让我知道问题出在哪里。

apache-kafka salesforce python-asyncio python-3.7 salesforce-lightning
1个回答
0
投票

我能够解决此问题,

它与库无关,非常棒。我能够实时获取消息。

问题出在我当前拥有的体系结构上,这导致了延迟。

谢谢大家的帮助。

我认为用这种方式回答不是很好,但是要回答,这样可能会使人抬起头来。在寻找此类错误时。

他们可以轻松地开始调试体系结构而不是库。

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