ConsumeSlackConversation 2025.5.31.15¶
Bundle¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
Beschreibung¶
Ruft Meldungen aus Slack-Konversationen ab, die für die App verfügbar sind. Neue Konversationen werden auf der Grundlage der „Reply Monitor Frequency“ abgerufen. Aufgenommene Meldungen werden im JSON-Format ausgegeben. Weitere Informationen dazu, wie Sie diesen Prozessor konfigurieren und ihn für den Abruf von Meldungen aus Slack aktivieren, finden Sie unter „Verwendung / Weitere Details“.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Zugriffstoken |
OAuth-Zugriffstoken für die Authentifizierung/Autorisierung der Slack-Anfrage, die von NiFi gesendet wird. Dies kann entweder ein Benutzer-Token oder ein Bot-Token sein. Je nach Art der Konversation muss ihr der Bereich „channels:history“, „groups:history“, „im:history“ oder „mpim:history“ zugewiesen werden. |
Batch Size |
Die maximale Anzahl von Meldungen, die in einer einzigen Anfrage an Slack abgerufen werden. Die gesamte Antwort wird in den Speicher geparst, daher ist es wichtig, dies bei der Einstellung dieses Werts zu berücksichtigen. |
Reply Monitor Frequency |
Nachdem er alle Meldungen in einem bestimmten Kanal empfangen hat, fragt dieser Prozessor in regelmäßigen Abständen alle „Thread-Meldungen“ (Antworten) ab, deren Zeitstempel zwischen dem aktuellen Zeitpunkt und dem in der Eigenschaft <Reply Monitor Window> angegebenen Zeitraum liegt. Diese Eigenschaft bestimmt, wie häufig diese Meldungen abgerufen werden. Wenn Sie den Wert auf eine kürzere Dauer einstellen, können Antworten auf Meldungen schneller erfasst werden, was zu einer geringeren Latenzzeit führt. Dies führt jedoch auch zu einem zusätzlichen Ressourcenverbrauch und kann eine Ratenbegrenzung auslösen. Dies bestimmt auch, wie häufig neu hinzugefügte Kanäle überprüft werden. |
Reply Monitor Window |
Nachdem er alle Meldungen in einem bestimmten Kanal empfangen hat, fragt dieser Prozessor in regelmäßigen Abständen alle „Thread-Meldungen“ (Antworten) ab, deren Zeitstempel zwischen dem aktuellen Zeitpunkt und einem definierten Zeitraum in der Vergangenheit liegt, um auf neue Antworten zu prüfen. Wenn Sie diesen Wert auf einen höheren Wert setzen, kann dies zu einer zusätzlichen Ressourcenauslastung und zu einer Ratenbegrenzung führen. Wenn ein Benutzer jedoch auf einen alten Thread antwortet, der außerhalb dieses Zeitfensters gestartet wurde, wird die Antwort möglicherweise nicht erfasst. |
Resolve Usernames |
Gibt an, ob Benutzer-IDs in Benutzernamen aufgelöst werden soll oder nicht. Standardmäßig geben Slack-Meldungen die ID des Benutzers an, der eine Meldung sendet, z. B. U0123456789, nicht aber den Benutzernamen, z. B. NiFiUser. Der Benutzername kann zwar aufgelöst werden, aber dazu sind möglicherweise zusätzliche Aufrufe an die Slack-API erforderlich. Außerdem muss dem verwendeten Token der Zugriffsbereich „users:read“ zugewiesen werden. Wenn diese Einstellung auf „true“ gesetzt ist, werden Benutzernamen nach dem Best-Effort-Prinzip aufgelöst: Kann ein Benutzername nicht ermittelt werden, wird er übersprungen. Beachten Sie auch, dass, wenn Sie einen Benutzernamen erhalten, das Feld <username> der Meldung ausgefüllt und das Feld <text> so aktualisiert wird, sodass jede Erwähnung als „Hallo @Benutzer“ anstelle von „Hallo <@U1234567>“ ausgegeben wird. |
Statusmanagement¶
Bereiche |
Beschreibung |
|---|---|
CLUSTER |
Hält eine Zuordnung von Slack-Kanal-IDs zum Zeitstempel der letzten Meldung aufrecht, die für diesen Kanal abgerufen wurde. Dadurch kann der Prozessor nur Meldungen abrufen, die seit der letzten Ausführung des Prozessors gepostet wurden. 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 |
Slack-Meldungen, die erfolgreich empfangen werden, werden an diese Beziehung weitergeleitet |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
slack.channel.id |
Die ID des Slack-Kanals, aus dem die Meldungen abgerufen wurden |
slack.message.count |
Die Anzahl der Slack-Meldungen, die im FlowFile enthalten sind |
mime.type |
Setzen Sie diese Option auf application/json, da die Ausgabe immer im JSON-Format erfolgen wird |