ConsumeAMQP

Описание

Получает сообщения AMQP от брокера AMQP, используя протокол AMQP 0.9.1. Каждое сообщение, полученное от брокера AMQP, будет отправлено как отдельный FlowFile в связь "success".

Теги

amqp, rabbit, get, message, receive, consume

Свойства

Название	Описание
Queue	Название существующей очереди AMQP, из которой будут извлекаться сообщения. Обычно задается администратором AMQP.
Auto-Acknowledge Messages	Если значение равно false (без автоматического подтверждения), сообщения будут подтверждены обработчиком после успешной передачи файлов Flow и фиксации сеанса NiFi. Режим без автоматического подтверждения обеспечивает семантику доставки «хотя бы один раз». Если значение true (автоматическое подтверждение), сообщения, доставляемые клиенту AMQP, будут автоматически подтверждаться брокером AMQP сразу после их отправки. Как правило, это обеспечивает лучшую пропускную способность, но также приводит к потере сообщений при перезапуске/аварийном завершении работы AMQP Broker, NiFi или процессора. Режим автоматического подтверждения обеспечивает семантику доставки не более одного раза и рекомендуется только в том случае, если допустима потеря сообщений.
Batch Size	Максимальное количество сообщений, которые должны быть обработаны за один сеанс. Как только будет получено указанное количество сообщений (или когда больше не будет доступных сообщений), полученные сообщения будут перенесены в отношение «успех», а брокеру AMQP будет отправлено подтверждение. Если установить большее значение, производительность может повыситься, особенно для очень маленьких сообщений, но при внезапном перезапуске NiFi может возникнуть дублирование сообщений.
Prefetch Count	Максимальное количество неотправленных сообщений для потребителя. Если у потребителя есть такое количество неотправленных сообщений, брокер AMQP больше не будет отправлять новые сообщения, пока потребитель не подтвердит получение некоторых из уже отправленных ему сообщений. Допустимые значения: от 0 до 65535. 0 означает отсутствие ограничений
Header Output Format	Определяет способ вывода заголовков из полученного сообщения
Header Key Prefix	Текст, добавляемый в качестве префикса к ключам заголовков при их добавлении в атрибуты FlowFile. Процессор добавит '.' к значению этого свойства.This Property is only considered if the [Header Output Format] Property has a value of "FlowFile Attributes".
Header Separator	The character that is used to separate key-value for header in String. The value must be only one character.This Property is only considered if the [Header Output Format] Property has a value of "Comma-Separated String".
Remove Curly Braces	Если значение равно true, удалите фигурные скобки, фигурные скобки в заголовке будут автоматически удалены.This Property is only considered if the [Header Output Format] Property has a value of "Comma-Separated String".
Brokers	Список известных брокеров AMQP, разделённых запятыми, в формате <хост>:<порт> (например, localhost:5672). Если это свойство задано, имя хоста и порт игнорируются. Включайте только хосты из одного кластера AMQP. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Host Name	Сетевой адрес брокера AMQP (например, localhost). Если задано свойство Brokers, это свойство игнорируется. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Port	Числовое значение, определяющее порт брокера AMQP (например, 5671). Если задано свойство Brokers, то это свойство игнорируется. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Virtual Host	Имя виртуального хоста, который отделяет систему AMQP для повышения безопасности. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
User Name	Имя пользователя, используемое для аутентификации и авторизации. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Password	Пароль, используемый для аутентификации и авторизации. Чувствительный параметр: true
AMQP Version	Версия AMQP. В настоящее время поддерживается только AMQP v0.9.1.
SSL Context Service	Служба контекста SSL, используемая для предоставления информации о сертификате клиента для подключений TLS/SSL.
Use Client Certificate Authentication	Аутентификация с использованием сертификата SSL, а не имени пользователя и пароля.

Взаимосвязи

• success: Все файлы Flow, полученные из очереди AMQP, направляются в это отношение