ConsumeSlackHistory 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
Beschreibung¶
Ruft historische Meldungen aus allen für die App verfügbaren Slack-Kanälen ab. Dieser Prozessor fragt die „conversations.history“ und „conversations.replies“ von Slack ab, um ältere Meldungen abzurufen, und gibt das Ergebnis als Datensätze aus. Der Prozessor verfolgt den frühesten Zeitstempel der abgerufenen Meldungen im Clusterstatus, damit er die historische Last bei nachfolgenden Ausführungen fortsetzen kann. Die Kanäle werden automatisch erkannt, es muss keine Kanal-ID oder kein Name konfiguriert werden.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Zugriffstoken |
OAuth-Zugriffstoken, das zur Authentifizierung der Slack-Anfrage verwendet wird. Ihm muss die Berechtigung „channels:history“ erteilt werden (sowie „users:read“, falls Benutzernamen aufgelöst werden sollen). |
Batch Size |
Die maximale Anzahl von Meldungen, die in einer einzigen Anfrage an Slack abgerufen werden. |
Channel Refresh Frequency |
Die Häufigkeit, mit der der Prozessor die Liste der für die App zugänglichen Slack-Kanäle aktualisiert. Dies hilft, neu verfügbare Kanäle zu erkennen oder nicht mehr verfügbare Kanäle zu entfernen. |
Include Message Blocks |
Gibt an, ob die JSON-Ausgabe den Wert des Feldes „Blocks“ für jede Slack-Meldung enthalten soll. |
Include Null Fields |
Legt fest, ob Felder, die Nullwerte haben, in die JSON-Ausgabe aufgenommen werden sollen. Bei „true“ wird jedes Feld mit einem Nullwert als Null ausgegeben; bei „false“, wird es ausgelassen. |
Resolve Usernames |
Gibt an, ob Benutzer-IDs in Benutzernamen aufgelöst werden sollen. Bei „true“ werden Benutzernamen nach dem Best-Effort-Prinzip aufgelöst. Wenn ein Benutzername nicht gefunden wird, wird er übersprungen. |
Statusmanagement¶
Bereiche |
Beschreibung |
|---|---|
CLUSTER |
Hält eine Zuordnung der Slack-Kanal-IDs zum frühesten Zeitstempel der abgerufenen Meldung aufrecht. Wenn keine weiteren Meldungen mehr verfügbar sind, wird ein Flag gesetzt, das anzeigt, dass die historische Last für diesen Kanal abgeschlossen ist. Dieser Status wird im Cluster gespeichert, sodass bei einem Wechsel des primären Knotens der neue Knoten dort weitermacht, wo der vorherige Knoten aufgehört hat. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
FlowFiles, die den JSON-codierten Slack-Konversationsverlauf enthalten, werden an diese Beziehung weitergeleitet |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
slack.channel.id |
Die ID des Slack-Kanals, aus dem die Meldungen abgerufen wurden |
slack.channel.name |
Der Name des Slack-Kanals, aus dem die Meldungen abgerufen wurden |
slack.message.count |
Die Anzahl der Slack-Meldungen, die im FlowFile enthalten sind |
mime.type |
Wenn Sie diese Option auf „application/json“ setzen, erfolgt die Ausgabe immer im JSON-Format. |