ConsumeSlack
Описание
Извлекает сообщения из одного или нескольких настроенных каналов Slack. Сообщения записываются в формате JSON. См. раздел Использование / Дополнительные сведения для получения информации о том, как настроить этот процессор и включить его для получения сообщений из Slack.
Теги
slack, conversation, conversation.history, social media, team, text, unstructured
Свойства
| Название | Описание |
|---|---|
| Channels | Список каналов Slack для получения сообщений, разделённых запятыми. Каждый элемент в списке может быть либо идентификатором канала, наприм ер C0L9VCD47, либо (только для общедоступных каналов) названием канала, начинающимся со знака #, например #general. Если вместо идентификатора канала указано его название, для определения идентификатора канала необходимо предоставить токен доступа с областью действия «чтение каналов». Дополнительные сведения о том, как найти идентификатор канала, см. в разделе «Дополнительные сведения» процессора. |
| Access Token | Токен доступа OAuth, используемый для аутентификации/авторизации запроса Slack, отправленного NiFi. Это может быть токен пользователя или токен бота. В зависимости от типа используемого диалога ему должна быть предоставлена область действия channels:history, groups:history, im:history или mpim:history. Чувствительный параметр: true |
| Reply Monitor Window | После обработки всех сообщений в заданном канале этот процессор будет периодически опрашивать все "потоковые сообщения", то есть ответы, временная метка которых находится между текущим моментом и этим промежутком времени в прошлом, чтобы проверить наличие любых новых ответов. Установка большего значения для этого параметра может привести к дополнительному использованию ресурсов и ограничению скорости. Однако, если пользователь отвечает на старый поток, который был запущен за пределами этого окна, ответ может быть не получен. |
| Reply Monitor Frequency | После обработки всех сообщений в заданном канале этот процессор будет периодически опрашивать все «последовательные сообщения», то есть ответы, отметка времени которых находится в диапазоне от текущего момента до момента, указанного в свойстве <Окно мониторинга ответов>. Это свойство определяет, как часто опрашиваются эти сообщения. Если установить более короткое значение, ответы на сообщения будут обрабатываться быстрее, что снизит задержку. Однако это также приведет к дополнительному использованию ресурсов и может вызвать ограничение скорости. |
| Batch Size | Максимальное количество сообщений, которые можно получить за один запрос к Slack. Весь ответ будет проанализирован в памяти, поэтому важно учитывать это при установке данного значения. |
| Resolve Usernames | Specifies whether or not User IDs should be resolved to usernames. By default, Slack Messages provide the ID of the user that sends a message, such as U0123456789, but not the username, such as NiFiUser. The username may be resolved, but it may require additional calls to the Slack API and requires that the Token used be granted the users:read scope. If set to true, usernames will be resolved with a best-effort policy: if a username cannot be obtained, it will be skipped over. Also, note that when a username is obtained, the Message's <username> field is populated, and the <text> field is updated such that any mention will be output such as "Hi @user" instead of "Hi <@U1234567>". |
| Include Message Blocks | Указывает, должен ли выходной JSON включать значение поля «блоки» для каждого сообщения Slack. Это поле содержит такую информацию, как отдельные части сообщения, отформатированные с помощью форматированного текста. Это может быть полезно, например, для синтаксического анализа. Однако на это часто приходится значительная часть данных, и поэтому, если это вам не нужно, можно установить значение null. |
| Include Null Fields | Указывает, следует ли включать поля с нулевыми значениями в выходной JSON. Если значение равно true, любое поле в сообщении Slack с нулевым значением будет включено в JSON со значением null. Если значение равно false, ключ полностью исключается из выходного JSON. Исключение нулевых значений приводит к уменьшению разм ера сообщений, которые, как правило, проще обрабатывать, но включение значений может обеспечить лучшее понимание формата, особенно при выводе схемы. |
Взаимосвязи
- success: Сообщения Slack, которые были успешно получены, будут перенаправлены в эту связь