ConsumeSlackHistory 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
Description¶
Récupère l’historique des messages de tous les canaux Slack disponibles pour l’application. Ce processeur interroge les méthodes conversations.history et conversations.replies de Slack pour récupérer les messages plus anciens et produit le résultat sous forme d’enregistrements. Le processeur suit l’horodatage du message récupéré le plus tôt dans l’état du cluster, ce qui lui permet de poursuivre le chargement de l’historique lors des exécutions suivantes. Les canaux sont découverts automatiquement, il n’est pas nécessaire de configurer l’ID ou le nom de canal.
Exigences en matière d’entrées¶
FORBIDDEN
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Jeton d’accès |
Jeton d’accès OAuth utilisé pour l’authentification de la requête Slack. Celui-ci doit se voir accorder le champ d’application channels:history (et, pour la résolution des noms d’utilisateur, users:read). |
Batch Size |
Le nombre maximum de messages à récupérer en une seule requête adressée à Slack. |
Fréquence de rafraîchissement du canal |
La fréquence à laquelle le processeur actualise la liste des canaux Slack accessibles à l’application. Cela permet de détecter les nouveaux canaux disponibles ou de supprimer ceux qui ne le sont plus. |
Include Message Blocks |
Indique si la sortie JSON doit inclure la valeur du champ « blocks » pour chaque message Slack. |
Include Null Fields |
Indique si les champs de valeur nulle doivent être inclus dans la sortie JSON. Si cette propriété est définie sur true, tout champ de valeur nulle apparaîtra dans la sortie avec une valeur nulle ; si elle est définie sur false, il sera omis. |
Resolve Usernames |
Indique si les ID utilisateur doivent être transformés en noms d’utilisateur. Si c’est le cas, les noms d’utilisateur seront résolus selon la politique du meilleur effort ; si un nom d’utilisateur ne peut être obtenu, il sera ignoré. |
Gestion de l’État¶
Champs d’application |
Description |
|---|---|
CLUSTER |
Maintient un mappage des ID de canal Slack avec l’horodatage du message le plus ancien qui a été récupéré. Lorsqu’il n’y a plus de messages disponibles, un indicateur est mis en place pour signaler que le chargement de l’historique est terminé pour ce canal. Cet état est stocké dans le cluster de sorte que si le nœud principal change, le nouveau nœud reprendra là où le précédent s’est arrêté. |
Relations¶
Nom |
Description |
|---|---|
success |
Les FlowFiles contenant l’historique des conversations Slack codé en JSON sont routés vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
slack.channel.id |
L’ID du canal Slack à partir duquel les messages ont été récupérés |
slack.channel.name |
Le nom du canal Slack à partir duquel les messages ont été récupérés |
slack.message.count |
Le nombre de messages Slack inclus dans le FlowFile |
mime.type |
Paramétré sur application/json : la sortie sera toujours au format JSON |