Slack エンティティからの読み取り
前提条件
-
読み取り元の Slack オブジェクト。
サポートされているエンティティ
| エンティティ | フィルタリング可能 | 制限をサポートする | Order By をサポートする | Select * をサポートする | パーティション分割をサポートする |
|---|---|---|---|---|---|
| 会話 | はい | あり | なし | あり | あり |
例
slack_read = glueContext.create_dynamic_frame.from_options( connection_type="slack", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "conversations/C058W38R5J8" } )
Slack エンティティとフィールドの詳細
| エンティティ | フィールド | データタイプ | サポートされている演算子 |
|---|---|---|---|
| 会話 | attachments | リスト | NA |
| 会話 | bot_id | 文字列 | NA |
| 会話 | blocks | リスト | NA |
| 会話 | client_msg_id | 文字列 | NA |
| 会話 | is_starred | ブール値 | NA |
| 会話 | last_read | 文字列 | NA |
| 会話 | latest_reply | 文字列 | NA |
| 会話 | reactions | リスト | NA |
| 会話 | replies | リスト | NA |
| 会話 | reply_count | 整数 | NA |
| 会話 | reply_users | リスト | NA |
| 会話 | reply_users_count | 整数 | NA |
| 会話 | subscribed | ブール値 | NA |
| 会話 | subtype | 文字列 | NA |
| 会話 | text | 文字列 | NA |
| 会話 | team | 文字列 | NA |
| 会話 | thread_ts | 文字列 | NA |
| 会話 | ts | 文字列 | EQUAL_TO、FORE, LESS_THAN, LESS_THAN_OR_EQUAL_TO, GREATER_THAN, GREATER_THAN_OR_EQUAL_TO |
| 会話 | type | 文字列 | NA |
| 会話 | ユーザー | 文字列 | NA |
| 会話 | inviter | 文字列 | NA |
| 会話 | ルート | Struct | NA |
| 会話 | is_locked | ブール値 | NA |
| 会話 | ファイル | リスト | NA |
| 会話 | 部屋 | Struct | NA |
| 会話 | アップロード | ブール値 | NA |
| 会話 | display_as_bot | ブール値 | NA |
| 会話 | チャンネル | 文字列 | NA |
| 会話 | no_notifications | ブール値 | NA |
| 会話 | permalink | 文字列 | NA |
| 会話 | pinned_to | リスト | NA |
| 会話 | pinned_info | Struct | NA |
| 会話 | edited | Struct | NA |
| 会話 | app_id | 文字列 | NA |
| 会話 | bot_profile | Struct | NA |
| 会話 | metadata | Struct | NA |
パーティショニングクエリ
Spark で同時実行を使用する場合は、追加の Spark オプション PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND、および NUM_PARTITIONS を指定できます。これらのパラメータを使用すると、元のクエリは Spark タスクで同時に実行できるサブクエリの NUM_PARTITIONS の数に分割されます。
-
PARTITION_FIELD: クエリのパーティション化に使用するフィールドの名前。 -
LOWER_BOUND: 選択したパーティションフィールドの包括的な下限値。日付については、Spark SQL クエリで使用される Spark の日付形式を受け入れます。有効な値の例:
"2024-07-01T00:00:00.000Z"。 -
UPPER_BOUND: 選択したパーティションフィールドの排他的上限値。 -
NUM_PARTITIONS: パーティション数。
エンティティごとのパーティション分割フィールドのサポートの詳細は、以下の表にまとめられています。
| エンティティ名 | Partitioning Field | データタイプ |
|---|---|---|
| 会話 | ts | 文字列 |
例
slack_read = glueContext.create_dynamic_frame.from_options( connection_type="slack", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "conversations/C058W38R5J8", "PARTITION_FIELD": "ts" "LOWER_BOUND": "2022-12-01T00:00:00.000Z" "UPPER_BOUND": "2024-09-23T15:00:00.000Z" "NUM_PARTITIONS": "2" } )
