APIréférence pour le connecteur Amazon Redshift Python

Vous trouverez ci-dessous une description des opérations du connecteur API Amazon Redshift Python.

redshift_connector

Vous trouverez ci-dessous une description de l'redshift_connectorAPIopération.

connect(user, database, password[, port, …])

Établit une connexion à un cluster Amazon Redshift. Cette fonction valide les entrées de l'utilisateur, s'authentifie éventuellement à l'aide d'un plugin de fournisseur d'identité, puis construit un objet de connexion.

apilevel

Le DBAPI niveau pris en charge, actuellement « 2.0 ».

paramstyle

str(object=’’) -> str str(bytes_or_buffer[, encoding[, errors]]) -> str

Style de API paramètre de base de données à utiliser globalement.

Connexion

Vous trouverez ci-dessous une description des API opérations de connexion pour le connecteur Amazon Redshift Python.

__init__(user, password, database[, host, …])

Initialise un objet de connexion brut.

cursor

Crée un objet de curseur lié à cette connexion.

commit

Valide la transaction de base de données actuelle.

rollback

Annule la transaction de base de données actuelle.

close

Ferme la connexion à la base de données.

execute(cursor, operation, vals)

Exécute la SQL commande spécifiée. Vous pouvez fournir les paramètres sous forme de séquence ou de mappage, en fonction de la valeur de redshift_connector.paramstyle.

run(sql[, stream])

Exécute la SQL commande spécifiée. Vous pouvez éventuellement fournir un flux à utiliser avec la COPY commande.

xid(format_id, global_transaction_id, …)

Créez un ID de transaction. Seul le paramètre global_transaction_id est utilisé dans postgres. format_id et branch_qualifier ne sont pas utilisés dans postgres. Le global_transaction_id peut être n'importe quel identifiant de chaîne pris en charge par postgres qui renvoie un tuple (format_id, global_transaction_id, branch_qualifier).

tpc_begin(xid)

Commence une TPC transaction avec un identifiant de transaction xid composé d'un identifiant de format, d'un identifiant de transaction global et d'un qualificatif de succursale.

tpc_prepare

Effectue la première phase d'une transaction démarrée avec .tpc_begin.

tpc_commit([xid])

Lorsqu'il est appelé sans argument, .tpc_commit valide une TPC transaction préalablement préparée avec .tpc_prepare ().

tpc_rollback([xid])

Lorsqu'il est appelé sans argument, .tpc_rollback annule une transaction. TPC

tpc_recover

Renvoie une liste de transactions en attente IDs pouvant être utilisées avec .tpc_commit (xid) ou .tpc_rollback (xid).

Curseur

Vous trouverez ci-dessous une description du API fonctionnement du curseur.

__init__(connection[, paramstyle])

Initialise un objet de curseur brut.

insert_data_bulk(filename, table_name, parameter_indices, column_names, delimiter, batch_size)

Exécute une INSERT instruction groupée.

execute(operation[, args, stream, …])

Exécute une opération de base de données.

executemany(operation, param_sets)

Prépare une opération de base de données, puis l'exécute pour toutes les séquences de paramètres ou les mappages fournis.

fetchone

Récupère la ligne suivante d'un ensemble de résultats de requête.

fetchmany([num])

Récupère l'ensemble de lignes suivant d'un résultat de requête.

fetchall

Récupère toutes les lignes restantes d'un résultat de requête.

close

Fermez le curseur maintenant.

__iter__

Un objet de curseur peut être itéré pour récupérer les lignes d'une requête.

fetch_dataframe([num])

Renvoie un dataframe des résultats de la dernière requête.

write_dataframe(df, table)

Écrit le même dataframe de structure dans une base de données Amazon Redshift.

fetch_numpy_array([num])

Renvoie un NumPy tableau des derniers résultats de la requête.

get_catalogs

Amazon Redshift ne prend pas en charge plusieurs catalogues à partir d'une seule connexion. Amazon Redshift renvoie uniquement le catalogue actuel.

get_tables([catalog, schema_pattern, …])

Renvoie les tables publiques uniques définies par l'utilisateur au sein du système.

get_columns([catalog, schema_pattern, …])

Renvoie la liste de toutes les colonnes d'une table spécifique dans une base de données Amazon Redshift.

AdfsCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du AdfsCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.AdfsCredentialsProvider()
	

AzureCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du AzureCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.AzureCredentialsProvider()
	

BrowserAzureCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du BrowserAzureCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.BrowserAzureCredentialsProvider()
	

BrowserSamlCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du BrowserSamlCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.BrowserSamlCredentialsProvider()
	

OktaCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du OktaCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.OktaCredentialsProvider()
	

PingCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du PingCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.PingCredentialsProvider()
	

SamlCredentialsProvider plugin

Voici la syntaxe du API fonctionnement du SamlCredentialsProvider plugin pour le connecteur Amazon Redshift Python.

redshift_connector.plugin.SamlCredentialsProvider()