ConsumeSlackHistory 2025.5.31.15¶
バンドル¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
説明¶
本アプリで利用可能なすべてのSlackチャンネルから過去のメッセージを取得します。このプロセッサーはSlackのconversions.historyとconversions.repliesをクエリして古いメッセージを取得し、結果をレコードとして出力します。プロセッサーは、クラスタステートで最も早く取得されたメッセージのタイムスタンプを追跡し、後続の実行で履歴負荷を継続できるようにします。チャンネルは自動的に検出されるため、 ID やチャンネル名を構成する必要はありません。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
アクセストークン |
OAuth Slackリクエストの認証に使用するアクセストークンです。channels:履歴（ユーザー名を解決する場合はusers:read）スコープが付与されていなければなりません。 |
バッチサイズ |
Slackへの1回のリクエストで取得するメッセージの最大数。 |
チャンネル・リフレッシュ周波数 |
プロセッサがAppにアクセス可能なSlackチャンネルのリストを更新する頻度。これにより、新たに利用可能 となったチャンネルを検出したり、利用できなくなったチャンネルを削除したりすることができます。 |
メッセージブロックを含む |
出力 JSON に各 Slack メッセージの 'blocks' フィールドの値を含めるかどうかを指定します。 |
Nullフィールドを含む |
null 値を持つフィールドを出力 JSON に含めるかどうかを指定します。trueの場合、NULL値を持つフィールドはNULLとして出力され、falseの場合は省略されます。 |
ユーザー名の解決 |
User IDs をユーザー名に解決するかどうかを指定します。もしtrueを指定すると、ユーザ名はベストエフォートポリシーで解決され、 ユーザー名が取得できない場合はスキップされます。 |
状態管理¶
スコープ |
説明 |
|---|---|
CLUSTER |
Slack Channel IDs と、取得された最も古いメッセージのタイムスタンプのマッピングを保持します。これ以上メッセージが利用可能でなくなると、そのチャネルの履歴ロードが完了したことを示すフラグがセットされます。この状態はクラスタリングに保存され、プライマリノードが変更された場合、新しいノードが前のノードの状態を引き継ぎます。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
success |
JSONでエンコードされた Slack の会話履歴がルーティングされた FlowFiles を含みます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
slack.channel.id |
メッセージが取得された Slack チャンネルの ID |
slack.channel.name |
メッセージを取得した Slack チャンネルの名前。 |
Slack.メッセージ.数 |
FlowFile に含まれるSlackメッセージの数。 |
mime.type |
application/json にセットすると、出力は常に JSON 形式になります。 |