Как опубликовать пакетные сообщения в теме pubsub с повторным запросом

Question

Я прочитал весь этот документ: https://cloud.google.com/pubsub/docs/publisher есть 3 примера:

1. Публикация по теме
2. Публикация в пакетном режиме
3. Публикация с повторными запросами

Я хочу объединить примеры 2 и 3 в один, чтобы публикация в пакетном режиме работала с повторными запросами. Как я могу это сделать?

Answer 1

Предмет pubsub_v1.PublisherClient принимает оба параметра как входные для конструкции.

Включив два необязательных параметра batch_settings а также client_config вы можете настроить пакетный режим с повторными запросами.

from google.cloud import pubsub_v1

publisher_client = pubsub_v1.PublisherClient(
    # Optional Batch param
    batch_settings = pubsub_v1.types.BatchSettings(
        max_bytes=1024,  # One kilobyte
        max_latency=1,   # One second
    ),

    # Optional Retrying param
    client_config = {
        "interfaces": {
            "google.pubsub.v1.Publisher": {
                "retry_params": {
                    "messaging": {
                        'total_timeout_millis': 650000,  # default: 600000
                    }
                }
            }
        }
    },

    # Optional
    client_options = {
        "api_endpoint": REGIONAL_ENDPOINT
    }
)