Не удалось получить сообщение в виде пакета от канала, подписанного с использованием aiosfstream, Python библиотека для salesforce

Question

Я пытаюсь подписаться на канал продаж, мне удалось получить сообщения из канала. Но проблема в том, что я получаю сообщения одно за другим, ожидаемый способ получения - это когда массовые сообщения публикуются на канале. Нужно получать сообщения целиком у подписчика.

Допустим, если я публикую sh 500 сообщений, мне нужно получить целых 500 сообщений здесь, на подписчике. Но я получаю одно сообщение за другим.

Я использую следующий код

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

Приведенный выше код вызывается внутри asyn c function

Я не являюсь Убедитесь, что это ошибка из библиотеки или неправильный метод, которым я пользуюсь

Пожалуйста, дайте мне знать, в чем проблема.

Answer 1

Мне удалось выяснить эту проблему,

Это не связано с библиотекой, это супер круто. Я смог получить сообщение в режиме реального времени.

Проблема была в архитектуре, которая у меня есть в настоящее время, что вызывает задержку.

Спасибо всем за помощь.

Я вижу, что не очень хорошо отвечать таким образом, но отвечаю так, чтобы это могло кого-то озадачить. При поиске таких ошибок.

Они могут легко начать отладку архитектуры вместо библиотеки.