无法从使用 aiosfstream、Python salesforce 库订阅的频道批量接收消息
Not able to receive message as a batch from the channel subscribed using aiosfstream, Python library for salesforce
我正在尝试订阅 salesforce 频道，我能够从该频道获取消息。
但问题是我一个接一个地收到消息，预期的接收方式是将批量消息发布到频道。需要在订阅者中整体获取消息。
假设我发布了 500 条消息，我需要在订阅者这里获取全部 500 条消息。但是我一个接一个地收到消息。
我正在使用以下代码
async with client:
for topic in get_topics(system='salesforce'):
await client.subscribe(topic)
async for message in client:
messages = message
以上代码在异步函数中调用
我不确定这是库中的错误还是我遵循的方法有误
请告诉我问题是什么。
我能够解决这个问题，
与图书馆无关，超级牛逼。我能够实时收到消息。
问题出在我目前的架构上，这导致了延迟。
谢谢大家的帮助。
我觉得这样回答不太好，但这样回答可能会给别人提个醒。在查找此类错误时。
他们可以轻松地开始调试体系结构而不是库。
我正在尝试订阅 salesforce 频道，我能够从该频道获取消息。 但问题是我一个接一个地收到消息，预期的接收方式是将批量消息发布到频道。需要在订阅者中整体获取消息。
假设我发布了 500 条消息，我需要在订阅者这里获取全部 500 条消息。但是我一个接一个地收到消息。
我正在使用以下代码
async with client:
for topic in get_topics(system='salesforce'):
await client.subscribe(topic)
async for message in client:
messages = message
以上代码在异步函数中调用
我不确定这是库中的错误还是我遵循的方法有误
请告诉我问题是什么。
我能够解决这个问题，
与图书馆无关，超级牛逼。我能够实时收到消息。
问题出在我目前的架构上，这导致了延迟。
谢谢大家的帮助。
我觉得这样回答不太好，但这样回答可能会给别人提个醒。在查找此类错误时。
他们可以轻松地开始调试体系结构而不是库。