Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Prerequisiti
-
Un oggetto Slack da cui si desidera leggere.
Entità supportate
Entità | Può essere filtrato | Supportato Limite | Supportato Order By | Supporta Select * | Supporta il partizionamento |
---|---|---|---|---|---|
conversazioni | Sì | Sì | No | Sì | Sì |
Esempio
slack_read = glueContext.create_dynamic_frame.from_options(
connection_type="slack",
connection_options={
"connectionName": "connectionName",
"ENTITY_NAME": "conversations/C058W38R5J8"
}
)
dettagli sull'entità e sui campi di Slack
Entità | Campo | Tipo di dati | Operatori supportati |
---|---|---|---|
conversazioni | allegati | Elenco | N/A |
conversazioni | bot_id | Stringa | N/A |
conversazioni | blocchi | Elenco | N/A |
conversazioni | client_msg_id | Stringa | N/A |
conversazioni | è contrassegnato da un asterisco | Booleano | N/A |
conversazioni | ultima lettura | Stringa | N/A |
conversazioni | ultima_risposta | Stringa | N/A |
conversazioni | reazioni | Elenco | N/A |
conversazioni | risposte | Elenco | N/A |
conversazioni | reply_count | Numero intero | N/A |
conversazioni | reply_users | Elenco | N/A |
conversazioni | reply_users_count | Numero intero | N/A |
conversazioni | sottoscritto | Booleano | N/A |
conversazioni | sottotipo | Stringa | N/A |
conversazioni | text | Stringa | N/A |
conversazioni | squadra | Stringa | N/A |
conversazioni | thread_ts | Stringa | N/A |
conversazioni | ts | Stringa | EQUAL_A,, LESS _ BETWEENTHAN, _ LESS _OR_ THAN _A, _, _ EQUAL GREATER _OR_ THAN _A GREATER THAN EQUAL |
conversazioni | tipo | Stringa | N/A |
conversazioni | Utente | Stringa | N/A |
conversazioni | invitante | Stringa | N/A |
conversazioni | root | Struct | N/A |
conversazioni | è bloccato | Booleano | N/A |
conversazioni | files | Elenco | N/A |
conversazioni | stanza | Struct | N/A |
conversazioni | caricamento | Booleano | N/A |
conversazioni | mostra_come_bot | Booleano | N/A |
conversazioni | canale | Stringa | N/A |
conversazioni | nessuna_notifica | Booleano | N/A |
conversazioni | permalink | Stringa | N/A |
conversazioni | appuntato_a | Elenco | N/A |
conversazioni | pinned_info | Struct | N/A |
conversazioni | modificato | Struct | N/A |
conversazioni | app_id | Stringa | N/A |
conversazioni | bot_profile | Struct | N/A |
conversazioni | metadata | Struct | N/A |
Interrogazioni di partizionamento
Se desideri utilizzare la concorrenza in Spark PARTITION_FIELD
LOWER_BOUND
UPPER_BOUND
, NUM_PARTITIONS
possono essere fornite opzioni Spark aggiuntive,,. Con questi parametri, la query originale verrebbe suddivisa in un NUM_PARTITIONS
numero di sottoquery che possono essere eseguite contemporaneamente dalle attività di Spark.
-
PARTITION_FIELD
: il nome del campo da utilizzare per partizionare la query. -
LOWER_BOUND
: un valore limite inferiore inclusivo del campo di partizione scelto.Per la data, accettiamo il formato di data Spark utilizzato nelle query SQL Spark. Esempio di valore valido:.
"2024-07-01T00:00:00.000Z"
-
UPPER_BOUND
: un valore limite superiore esclusivo del campo di partizione scelto. -
NUM_PARTITIONS
: numero di partizioni.
I dettagli del supporto del campo di partizionamento di Entity Wise sono riportati nella tabella seguente.
Nome entità | Campo di partizionamento | Tipo di dati |
---|---|---|
conversazioni | ts | Stringa |
Esempio
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"
}
)