前提条件
-
読み取り元の Slack オブジェクト。
サポートされているエンティティ
エンティティ | フィルタリング可能 | 制限をサポートする | Order By をサポートする | Select * をサポートする | パーティション分割をサポートする |
---|---|---|---|---|---|
会話 | あり | はい | いいえ | はい | はい |
例
slack_read = glueContext.create_dynamic_frame.from_options(
connection_type="slack",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "conversations/C058W38R5J8"
}
)
Slack エンティティとフィールドの詳細
エンティティ | フィールド | データタイプ | サポートされる演算子 |
---|---|---|---|
会話 | 添付ファイル | リスト | 該当なし |
会話 | bot_id | 文字列 | 該当なし |
会話 | blocks | リスト | 該当なし |
会話 | client_msg_id | 文字列 | 該当なし |
会話 | is_starred | ブール値 | 該当なし |
会話 | last_read | 文字列 | 該当なし |
会話 | latest_reply | 文字列 | 該当なし |
会話 | reactions | リスト | 該当なし |
会話 | replies | リスト | 該当なし |
会話 | reply_count | 整数 | 該当なし |
会話 | reply_users | リスト | 該当なし |
会話 | reply_users_count | 整数 | 該当なし |
会話 | subscribed | ブール値 | 該当なし |
会話 | subtype | 文字列 | 該当なし |
会話 | text | 文字列 | 該当なし |
会話 | team | 文字列 | 該当なし |
会話 | thread_ts | 文字列 | 該当なし |
会話 | ts | 文字列 | EQUAL_TO、FORE, LESS_THAN, LESS_THAN_OR_EQUAL_TO, GREATER_THAN, GREATER_THAN_OR_EQUAL_TO |
会話 | type | 文字列 | 該当なし |
会話 | ユーザー | 文字列 | 該当なし |
会話 | inviter | 文字列 | 該当なし |
会話 | ルート | Struct | 該当なし |
会話 | is_locked | ブール値 | 該当なし |
会話 | ファイル | リスト | 該当なし |
会話 | 部屋 | Struct | 該当なし |
会話 | アップロード | ブール値 | 該当なし |
会話 | display_as_bot | ブール値 | 該当なし |
会話 | チャンネル | 文字列 | 該当なし |
会話 | no_notifications | ブール値 | 該当なし |
会話 | permalink | 文字列 | 該当なし |
会話 | pinned_to | リスト | 該当なし |
会話 | pinned_info | Struct | 該当なし |
会話 | edited | Struct | 該当なし |
会話 | app_id | 文字列 | 該当なし |
会話 | bot_profile | Struct | 該当なし |
会話 | metadata | Struct | 該当なし |
パーティショニングクエリ
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"
}
)