Riferimento API per il connettore Python di Amazon Redshift - Amazon Redshift

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".

paramstyle
str(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. La global_transaction_id può 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 xid costituito 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()