Задержка обработки метода обратного вызова в Google PubSub - PullRequest
Новая
       6

Задержка обработки метода обратного вызова в Google PubSub

0 голосов
/ 29 августа 2018

Я пытаюсь передать сообщение от издателя одному из моих подписчиков в Google Pub / Sub. Я думаю, что задержка в методе обратного вызова распознается подписчиком поздно. Ниже приведен пример:

Я выполнил метод обратного вызова, как показано ниже: 

def callback(message):
    print(message.data)
    message.ack()

Я пытаюсь опубликовать контент от издателя 

publisher.publish(topic,b"Hi hello",spam="eggs")

Результатом является b'hi hello ', так как я печатаю только message.data в обратном вызове.

Теперь я меняю функцию обратного вызова 

def callback(message):
    print(message.data)
    print("hello message")
    message.ack()

Результат, когда я публикую контент, все равно b'hi hello ', и он не показывает "привет сообщение". После ожидания в течение 2-3 минут он, наконец, показывает фактический результат в обратном вызове, когда я выполняю его снова.

Не могли бы вы помочь мне решить эту задержку, если это возможно?

Спасибо

...