Как ограничить количество потоков на издателе в Google Pub / Sub? - PullRequest
Новая
       39

Как ограничить количество потоков на издателе в Google Pub / Sub?

0 голосов
/ 04 октября 2018

В настоящее время я использую Google pub / sub и использую библиотеку Google pubsub python.Я не могу найти способ ограничить количество потоков, порождаемых на моей машине, которое использует большинство моих ресурсов.

Вот мой код: 

def publish(data):
  def callback(message_future):
    if message_future.exception(timeout=3):
      self.logger.error('Publishing message on {} threw an Exception {}.'.format(topic_name, message_future.exception()))

  data = data.encode('utf-8')
  message_future = self.publisher.publish(topic_path, data=data)
  message_future.add_done_callback(callback)
...