ConsumeSlack 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-slack-nar
Descrição¶
Recupera mensagens de um ou mais canais configurados do Slack. As mensagens são gravadas no formato JSON. Consulte Uso/detalhes adicionais para obter mais informações sobre como configurar esse processador e habilitá-lo para recuperar mensagens do Slack.
Requisito de entrada¶
FORBIDDEN
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Token de acesso |
Token de acesso OAuth usado para autenticar/autorizar a solicitação do Slack enviada por NiFi. Pode ser um token de usuário ou um token de bot. Ele deve receber o escopo channels:history, groups:history, im:history ou mpim:history, dependendo do tipo de conversa que estiver sendo usada. |
Tamanho do lote |
O número máximo de mensagens a serem recuperadas em uma única solicitação ao Slack. A resposta inteira será analisada na memória, portanto, é importante que você tenha isso em mente ao definir esse valor. |
Canais |
Uma lista separada por vírgulas de canais do Slack para recuperar mensagens. Cada elemento da lista pode ser um ID de canal, como C0L9VCD47, ou (somente para canais públicos) o nome de um canal, prefixado com um sinal #, como #general. Se qualquer nome de canal for fornecido, em vez de um ID, o token de acesso fornecido deverá receber o escopo channels:read para resolver o ID de canal. Consulte os detalhes adicionais do processador para obter informações sobre como encontrar um ID de canal. |
Inclusão de blocos de mensagem |
Especifica se a saída JSON deve ou não incluir o valor do campo de blocos para cada mensagem do Slack. Esse campo inclui informações como partes individuais de uma mensagem que são formatadas usando rich text. Isso pode ser útil, por exemplo, para análise. No entanto, ele geralmente representa uma parte significativa dos dados e, portanto, pode ser definido como nulo quando não for útil para você. |
Inclusão de campos nulos |
Especifica se os campos com valores nulos devem ou não ser incluídos na saída JSON. Se for verdadeiro, qualquer campo em uma mensagem do Slack que tenha um valor nulo será incluído no JSON com um valor nulo. Se falso, a chave é inteiramente omitida de JSON de saída. A omissão de valores nulos resulta em mensagens menores que geralmente são mais eficientes para processamento, mas a inclusão dos valores pode proporcionar uma melhor compreensão do formato, especialmente para a inferência de esquema. |
Frequência do monitor de resposta |
Após consumir todas as mensagens em um determinado canal, esse processador pesquisará periodicamente todas as “mensagens encadeadas”, também conhecidas como respostas, cujo carimbo de data/hora esteja entre agora e o período de tempo especificado pela propriedade <Janela de monitoramento de resposta>. Essa propriedade determina a frequência com que essas mensagens são pesquisadas. Definir o valor para uma duração mais curta pode fazer com que as respostas às mensagens sejam capturadas mais rapidamente, proporcionando uma latência menor. No entanto, isso também resultará em uso adicional de recursos e poderá acionar a ocorrência de limitação de taxa. |
Janela de monitoramento de resposta |
Após consumir todas as mensagens em um determinado canal, esse processador pesquisará periodicamente todas as “mensagens encadeadas”, também conhecidas como respostas, cujo carimbo de data/hora esteja entre agora e esse período de tempo no passado, a fim de verificar se há novas respostas. A configuração desse valor como um valor maior pode resultar em uso adicional de recursos e pode resultar em limitação de taxa. No entanto, se um usuário responder a um tópico antigo iniciado fora dessa janela, a resposta poderá não ser capturada. |
Resolução de nomes de usuário |
Especifica se os IDs de usuário devem ou não ser resolvidos para nomes de usuário. Por padrão, as mensagens do Slack fornecem o ID do usuário que envia uma mensagem, como U0123456789, mas não o nome de usuário, como NiFiUser. O nome de usuário pode ser resolvido, mas isso pode exigir chamadas adicionais para a Slack API e requer que o token usado receba o escopo users:read. Se definido como verdadeiro, os nomes de usuário serão resolvidos com uma política de melhor esforço: se um nome de usuário não puder ser obtido, ele será ignorado. Além disso, observe que, quando um nome de usuário é obtido, o campo <username> da mensagem é preenchido e o campo <text> é atualizado de forma que qualquer menção seja emitida como “Hi @user” em vez de “Hi <@U1234567>”. |
Gerenciamento do estado¶
Escopos |
Descrição |
|---|---|
CLUSTER |
Mantém um mapeamento dos IDs de canal Slack para o carimbo de data/hora da última mensagem recuperada para esse canal. Isso permite que o processador recupere apenas as mensagens que foram postadas desde a última vez em que o processador foi executado. Esse estado é armazenado no cluster para que, se o nó primário mudar, o novo nó continue de onde o nó anterior parou. |
Relações¶
Nome |
Descrição |
|---|---|
success |
As mensagens do Slack que forem recebidas com sucesso serão encaminhadas para esse relacionamento |
Grava atributos¶
Nome |
Descrição |
|---|---|
slack.channel.id |
O ID do canal Slack do qual as mensagens foram recuperadas |
slack.message.count |
O número de mensagens do Slack que estão incluídas no FlowFile |
mime.type |
Defina como application/json, pois a saída estará sempre no formato JSON |