ConsumeSlackHistory 2025.5.31.15¶
번들¶
com.snowflake.openflow.runtime | runtime-slack-processors-nar
설명¶
앱에서 사용 가능한 모든 Slack 채널에서 과거 메시지를 가져옵니다. 이 프로세서는 Slack의 conversations.history 및 conversations.replies를 쿼리하여 이전 메시지를 검색하고 그 결과를 레코드로 출력합니다. 프로세서는 클러스터 상태에서 가장 먼저 검색된 메시지 타임스탬프를 추적하여 후속 실행에서 기록 로딩을 계속할 수 있도록 합니다. 채널은 자동으로 검색되며 ID 또는 이름을 구성할 필요가 없습니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
액세스 토큰 |
Slack 요청을 인증하는 데 사용되는 OAuth 액세스 토큰입니다. 채널:기록(사용자 이름을 확인하는 경우 사용자:읽기) 범위를 부여받아야 합니다. |
Batch Size |
Slack에 한 번의 요청으로 검색할 수 있는 최대 메시지 수입니다. |
Channel Refresh Frequency |
프로세서가 앱에 액세스할 수 있는 Slack 채널 목록을 새로 고치는 빈도입니다. 이를 통해 새로 사용 가능한 채널을 감지하거나 더 이상 사용할 수 없는 채널을 제거할 수 있습니다. |
Include Message Blocks |
JSON 출력에 각 Slack 메시지에 대한 ‘블록’ 필드 값을 포함할지 여부를 지정합니다. |
Include Null Fields |
Null 값을 가진 필드를 출력 JSON 에 포함할지 여부를 지정합니다. true이면 null 값이 있는 필드는 모두 null로 출력되고, false이면 생략됩니다. |
Resolve Usernames |
사용자 IDs 를 사용자 이름으로 확인할지 여부를 지정합니다. true이면 사용자 이름을 찾을 수 없는 경우 건너뛰는 최선의 노력 정책으로 사용자 이름을 확인합니다. |
상태 관리¶
범위 |
설명 |
|---|---|
CLUSTER |
검색된 가장 최근의 메시지 타임스탬프에 대한 Slack 채널 IDs 매핑을 유지합니다. 더 이상 사용 가능한 메시지가 없으면 해당 채널에 대한 기록 로딩이 완료되었음을 나타내는 플래그가 설정됩니다. 이 상태는 클러스터에 저장되므로 기본 노드가 변경되면 새 노드가 이전 노드가 중단한 부분을 이어받게 됩니다. |
관계¶
이름 |
설명 |
|---|---|
성공 |
JSON 으로 인코딩된 Slack 대화 기록을 포함하는 FlowFiles 은 이 관계로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
slack.channel.id |
메시지가 검색된 Slack 채널의 ID |
slack.channel.name |
메시지를 검색한 Slack 채널의 이름입니다 |
slack.message.count |
FlowFile 에 포함된 Slack 메시지의 수 |
mime.type |
application/json으로 설정하면 출력은 항상 JSON 형식이 됩니다 |