PublishGCPubSub
Описание
Публикует содержимое входящего FlowFile в настроенную тему Google Cloud PubSub. Процессор поддерживает динамические свойства. Если присутствуют динамические свойства, они будут отправлены вместе с сообщением в виде атрибутов.
Теги
google, google-cloud, gcp, message, pubsub, publish
Свойства
| Название | Описание |
|---|---|
| GCP Credentials Provider Service | Служба контроллера, используемая для получения учётных данных Google Cloud Platform. |
| Project ID | Google Cloud Project ID Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Topic Name | Имя темы Google Cloud PubSub Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Message Derivation Strategy | Стратегия, используемая для публикации входящего FlowFile в конечной точке Google Cloud PubSub. |
| Record Reader | Средство чтения записей, используемое для входящих FlowFilesThis Property is only considered if the [Message Derivation Strategy] Property has a value of "Record Oriented". |
| Record Writer | Средство записи, используемое для сериализации данных перед отправкой в конечную точку GCPubSubThis Property is only considered if the [Message Derivation Strategy] Property has a value of "Record Oriented". |
| Input Batch Size | Максимальное количество файлов Flow, обрабатываемых при каждом вызове процессора |
| Maximum Message Size | Максимальный размер сообщения Google PubSub в байтах. По умолчанию 1 МБ (1048576 байт)This Property is only considered if the [Message Derivation Strategy] Property has a value of "FlowFile Oriented". |
| Batch Size Threshold | Указывает количество сообщений, которые облачный сервис должен объединить в пакет. Если значение не задано и оставлено пустым, в пакете будет использоваться только одно сообщение |
| Batch Bytes Threshold | Publish request gets triggered based on this Batch Bytes Threshold property and the Batch Size Threshold property, whichever condition is met first. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Batch Delay Threshold | Указывает порог задержки, используемый для пакетной обработки. По истечении этого времени (считая с момента добавления первого элемента) элементы будут объединены в пакет и отправлены. Это значение не должно быть слишком высоким, обычно оно составляет порядка миллисекунд. В противном случае может показаться, что вызовы никогда не завершатся. |
| API Endpoint | Override the gRPC endpoint in the form of [host:port] Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Proxy Configuration Service | Specifies the Proxy Configuration Controller Service to proxy network requests. Supported proxies: HTTP + AuthN |
Взаимосвязи
- success: Файлы Flow направляются в это отношение после успешной операции Google Cloud Pub/Sub.
- failure: Файлы потока направляются в эту связь, если операция Google Cloud Pub/Sub завершается ошибкой.
- retry: Файлы потока направляются в эту связь, если операция Google Cloud Pub/Sub завершается ошибкой, но повторная попытка может оказаться успешной.