Amazon Redshift non supporterà più la creazione di nuove UDF Python a partire dal 1º novembre 2025. Se desideri utilizzare le UDF Python, creale prima di tale data. Le UDF Python esistenti continueranno a funzionare normalmente. Per ulteriori informazioni, consulta il post del blog
Riferimento API per il connettore Python di Amazon Redshift
Di seguito, puoi trovare una descrizione delle operazioni API del connettore Python di Amazon Redshift.
redshift_connector
Di seguito è riportata una descrizione dell'operazione API redshift_connector.
connect(user, database, password[, port, …])-
Stabilisce una connessione a un cluster Amazon Redshift. Questa funzione convalida l'input dell'utente, facoltativamente si autentica utilizzando un plugin del provider di identità e quindi crea un oggetto di connessione.
apilevel-
Il livello DBAPI supportato, attualmente "2.0".
paramstylestr(object=’’) -> str str(bytes_or_buffer[, encoding[, errors]]) -> str-
Lo stile dei parametri API del database da utilizzare a livello globale.
Connessione
Di seguito, puoi trovare una descrizione delle operazioni API di connessi per il connettore Python di Amazon Redshift.
__init__(user, password, database[, host, …])-
Inizializza un oggetto di connessione raw.
cursor-
Crea un oggetto cursore associato a questa connessione.
commit-
Esegue il commit della transazione corrente del database.
rollback-
Ripristina la transazione corrente del database.
close-
Chiude la connessione del database.
execute(cursor, operation, vals)-
Esegue i comandi SQL specificati. È possibile fornire i parametri come sequenza o come mappatura, a seconda del valore di
redshift_connector.paramstyle. run(sql[, stream])-
Esegue i comandi SQL specificati. In alternativa, puoi fornire un flusso da utilizzare con il comando COPY.
xid(format_id, global_transaction_id, …)-
Crea un ID transazione. Solo il parametro
global_transaction_idè usato in postgres. format_id e branch_qualifier non vengono utilizzati in postgres. Laglobal_transaction_idpuò essere qualsiasi identificatore di stringa supportato da postgres che restituisce una tupla (format_id,global_transaction_id,branch_qualifier). tpc_begin(xid)-
Inizia una transazione TPC con un ID transazione
xidcostituito da un ID formato, un ID transazione globale e un qualificatore di filiale. tpc_prepare-
Esegue la prima fase di una transazione iniziata con .tpc_begin.
tpc_commit([xid])-
Quando viene chiamato senza argomenti, .tpc_commit commette una transazione TPC precedentemente preparata con .tpc_prepare ().
tpc_rollback([xid])-
Quando viene chiamato senza argomenti, .tpc_rollback ripristina una transazione TPC.
tpc_recover-
Restituisce un elenco di ID transazione in sospeso adatti all'uso con .tpc_commit (xid) o .tpc_rollback (xid).
Cursore
Di seguito, potete trovare una descrizione dell'operazione API del cursore.
__init__(connection[, paramstyle])-
Inizializza un oggetto cursore non elaborato.
insert_data_bulk(filename, table_name, parameter_indices, column_names, delimiter, batch_size)-
Esegue un'istruzione INSERT in blocco.
execute(operation[, args, stream, …])-
Esegue un'operazione di database.
executemany(operation, param_sets)-
Prepara un'operazione di database e quindi la esegue per tutte le sequenze di parametri o mappature fornite.
fetchone-
Recupera la riga successiva di un set di risultati della query.
fetchmany([num])-
Recupera il prossimo set di righe del risultato di una query.
fetchall-
Recupera tutte le righe rimanenti di un risultato di una query.
close-
Chiude il cursore adesso.
__iter__-
Un oggetto cursore può essere iterato per recuperare le righe da una query.
fetch_dataframe([num])-
Restituisce un dataframe dei risultati dell'ultima query.
write_dataframe(df, table)-
Scrive lo stesso dataframe della struttura in un database Amazon Redshift.
fetch_numpy_array([num])-
Restituisce una matrice NumPy dei risultati dell'ultima query.
get_catalogs-
Amazon Redshift non supporta più cataloghi provenienti da una singola connessione. Amazon Redshift restituisce solo il catalogo corrente.
get_tables([catalog, schema_pattern, …])-
Restituisce le tabelle pubbliche univoche definite dall'utente all'interno del sistema.
get_columns([catalog, schema_pattern, …])-
Restituisce un elenco di tutte le colonne di una tabella specifica in un database Amazon Redshift.
Plugin AdfScredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin AdfsCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.AdfsCredentialsProvider()
Plugin AzurecredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin AzureCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.AzureCredentialsProvider()
plugin BrowserAzureCredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin BrowserAzureCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.BrowserAzureCredentialsProvider()
Plugin BrowserSamlCredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin BrowserSamlCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.BrowserSamlCredentialsProvider()
Plugin OktaCredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin OktaCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.OktaCredentialsProvider()
Plugin PingCredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin PingCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.PingCredentialsProvider()
Plugin SamlCredentialsProvider
Di seguito è riportata la sintassi per l'operazione API del plugin SamlCredentialsProvider per il connettore Python di Amazon Redshift.
redshift_connector.plugin.SamlCredentialsProvider()