Leitura de entidades do Slack
Pré-requisitos
-
Um objeto do Slack do qual você deseja ler.
Entidades compatíveis
| Entidade | Pode ser filtrada | Oferece suporte a limite | Oferece suporte a Ordenar por | Oferece suporte a Selecionar * | Oferece suporte a particionamento |
|---|---|---|---|---|---|
| conversas | Sim | Sim | Não | Sim | Sim |
Exemplo
slack_read = glueContext.create_dynamic_frame.from_options( connection_type="slack", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "conversations/C058W38R5J8" } )
Detalhes das entidades e dos campos do Slack
| Entidade | Campo | Tipo de dado | Operadores com suporte |
|---|---|---|---|
| conversas | anexos | Lista | NA |
| conversas | bot_id | String | NA |
| conversas | blocks | Lista | NA |
| conversas | client_msg_id | String | NA |
| conversas | is_starred | Booleano | NA |
| conversas | last_read | String | NA |
| conversas | latest_reply | String | NA |
| conversas | reações | Lista | NA |
| conversas | responde | Lista | NA |
| conversas | reply_count | Inteiro | NA |
| conversas | reply_users | Lista | NA |
| conversas | reply_users_count | Inteiro | NA |
| conversas | inscrito | Booleano | NA |
| conversas | subtipo | String | NA |
| conversas | text | String | NA |
| conversas | team | String | NA |
| conversas | thread_ts | String | NA |
| conversas | ts | String | EQUAL_TO, BETWEEN, LESS_THAN, LESS_THAN_OR_EQUAL_TO, GREATER_THAN, GREATER_THAN_OR_EQUAL_TO |
| conversas | type | String | NA |
| conversas | usuário | String | NA |
| conversas | anfitrião | String | NA |
| conversas | raiz | Struct | NA |
| conversas | is_locked | Booleano | NA |
| conversas | files | Lista | NA |
| conversas | sala | Struct | NA |
| conversas | buffer de | Booleano | NA |
| conversas | display_as_bot | Booleano | NA |
| conversas | channel | String | NA |
| conversas | no_notifications | Booleano | NA |
| conversas | permalink | String | NA |
| conversas | pinned_to | Lista | NA |
| conversas | pinned_info | Struct | NA |
| conversas | editado | Struct | NA |
| conversas | app_id | String | NA |
| conversas | bot_profile | Struct | NA |
| conversas | metadados | Struct | NA |
Particionamento de consultas
Podem ser fornecidas as opções adicionais do Spark PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND e NUM_PARTITIONS se você quiser utilizar a simultaneidade no Spark. Com esses parâmetros, a consulta original seria dividida em NUM_PARTITIONS subconsultas, que poderiam ser executadas pelas tarefas do Spark simultaneamente.
-
PARTITION_FIELD: o nome do campo a ser usado para particionar a consulta. -
LOWER_BOUND: um valor limite inferior inclusivo do campo de partição escolhido.Na data, aceitamos o formato de data do Spark usado em consultas SQL do Spark. Exemplo de valor válido:
"2024-07-01T00:00:00.000Z". -
UPPER_BOUND: um valor limite superior exclusivo do campo de partição escolhido. -
NUM_PARTITIONS: número de partições.
Os detalhes do suporte do campo de particionamento relativo às entidades são capturados na tabela a seguir.
| Entity Name | Campo de particionamento | Tipo de dado |
|---|---|---|
| conversas | ts | String |
Exemplo
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" } )
