ConsumeSlackHistory 2025.5.31.15¶
Pacote¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
Descrição¶
Obtém mensagens históricas de todos os canais Slack disponíveis para o aplicativo. Esse processador consulta o conversations.history e o conversations.replies do Slack para recuperar mensagens mais antigas e gera o resultado como registros. O processador rastreia o carimbo de data/hora da mensagem recuperada mais antiga no estado do cluster para permitir que ele continue a carga histórica nas execuções subsequentes. Os canais são descobertos automaticamente, não é necessário configurar o ID canal ou nome.
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 a solicitação do Slack. Ele deve receber o escopo channels:history (e, se estiver resolvendo nomes de usuário, users:read). |
Tamanho do lote |
O número máximo de mensagens a serem recuperadas em uma única solicitação ao Slack. |
Frequência de atualização do canal |
A frequência com que o processador atualiza a lista de canais Slack acessíveis ao aplicativo. Isso ajuda a detectar novos canais disponíveis ou a remover canais que não estão mais disponíveis. |
Inclusão de blocos de mensagem |
Especifica se a saída JSON deve incluir o valor do campo “blocks” para cada mensagem do Slack. |
Inclusão de campos nulos |
Especifica se os campos com valores nulos devem ser incluídos na saída JSON. Se verdadeiro, qualquer campo com um valor nulo será gerado como nulo; se for falso, será omitido. |
Resolução de nomes de usuário |
Especifica se os IDs de usuário devem ser resolvidos para nomes de usuário. Se for 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. |
Gerenciamento do estado¶
Escopos |
Descrição |
|---|---|
CLUSTER |
Mantém um mapeamento dos IDs de canal Slack para o carimbo de data/hora da mensagem mais antiga que foi recuperada. Quando não houver mais mensagens disponíveis, será definido um sinalizador indicando que o carregamento histórico foi concluído para esse canal. 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 |
FlowFiles contendo o histórico de conversas do Slack codificado em JSON são encaminhados para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
slack.channel.id |
O ID do canal Slack do qual as mensagens foram recuperadas |
slack.channel.name |
O nome 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 |
Definido como application/json, a saída estará sempre no formato JSON |