Skip to main content

PublishGCPubSubLite

Описание

Публикует содержимое входящего FlowFile в настроенную тему Google Cloud PubSub Lite. Процессор поддерживает динамические свойства. Если присутствуют динамические свойства, они будут отправлены вместе с сообщением в виде атрибутов.

Теги

google, google-cloud, gcp, message, pubsub, publish, lite

Свойства

НазваниеОписание
GCP Credentials Provider ServiceСлужба контроллера, используемая для получения учётных данных Google Cloud Platform.
Topic NameНазвание темы Google Cloud PubSub. Пример: проекты/8476107443/местоположения/европа-запад1-d/темы/моя-тема-lite Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Ordering KeyMessages with the same ordering key will always get published to the same partition. When this property is not set, messages can get published to different partitions if more than one partition exists for the topic. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Batch Size ThresholdУказывает количество сообщений, которые облачный сервис должен объединить в пакет. Если значение не задано и оставлено пустым, в пакете будет использоваться только одно сообщение
Batch Bytes ThresholdPublish 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Указывает порог задержки, используемый для пакетной обработки. По истечении этого времени (считая с момента добавления первого элемента) элементы будут объединены в пакет и отправлены. Это значение не должно быть слишком высоким, обычно оно составляет порядка миллисекунд. В противном случае может показаться, что вызовы никогда не завершатся.

Взаимосвязи

  • failure: Файлы потока направляются в эту связь, если операция Google Cloud Pub/Sub завершается ошибкой.
  • success: Файлы Flow направляются в это отношение после успешной операции Google Cloud Pub/Sub.