ConsumeSlackHistory 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
描述¶
从应用程序可用的所有 Slack 通道中提取历史消息。该处理器查询 Slack 的 conversations.history 和 conversations.replies 以检索较早的消息，并将结果作为记录输出。该处理器跟踪群集状态下最早检索到的消息时间戳，以允许它在后续执行时继续执行历史加载。通道是自动发现的，无需配置通道 ID 或名称。
输入要求¶
FORBIDDEN
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
访问令牌 |
用于对 Slack 请求进行身份验证的 OAuth 访问令牌。必须向其授予 channels: history（如果解析用户名，还有 users:read）范围。 |
批处理大小 |
通过向 Slack 发出的单个请求可以检索的最大消息数量。 |
通道刷新频率 |
该处理器刷新应用程序可访问的 Slack 通道列表的频率。这有助于检测新的可用通道或移除不再可用的通道。 |
包括消息块 |
指定输出 JSON 是否应包含每条 Slack 消息的“block”字段的值。 |
包括 Null 字段 |
指定输出 JSON 中是否应包含空值的字段。如果为 true，则任何具有空值的字段都将输出为 null；如果为 false，则将其省略。 |
解析用户名 |
指定是否应将用户 IDs 解析为用户名。如果为 true，则将使用“尽力而为”的策略解析用户名；如果无法获取用户名，则会跳过该用户名。 |
状态管理¶
范围 |
描述 |
|---|---|
CLUSTER |
维护 Slack 通道 IDs 与已检索到的最早消息时间戳的映射。当没有更多可用消息时，将设置一个标志，表示该通道的历史加载已完成。此状态会存储在集群中，因此，如果主节点发生变化，新节点将从上一个节点中断的地方继续。 |
关系¶
名称 |
描述 |
|---|---|
success |
包含 JSON 编码的 Slack 对话历史记录的 FlowFiles 将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
slack.channel.id |
从中检索消息的 Slack 通道的 ID |
slack.channel.name |
从中检索消息的 Slack 通道的名称 |
slack.message.count |
FlowFile 中包含的 Slack 消息的数量 |
mime.type |
设置为 application/json，输出将始终采用 JSON 格式 |