Referensi API untuk konektor Amazon Redshift Python - Amazon Redshift
redshift_connector Koneksi Kursor AdfsCredentialsProvider plugin AzureCredentialsProvider plugin BrowserAzureCredentialsProvider plugin BrowserSamlCredentialsProvider plugin OktaCredentialsProvider plugin PingCredentialsProvider plugin SamlCredentialsProvider plugin

Amazon Redshift tidak akan lagi mendukung pembuatan Python UDFs baru mulai 1 November 2025. Jika Anda ingin menggunakan Python UDFs, buat UDFs sebelum tanggal tersebut. Python yang ada UDFs akan terus berfungsi seperti biasa. Untuk informasi lebih lanjut, lihat posting blog.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Referensi API untuk konektor Amazon Redshift Python

Berikut ini, Anda dapat menemukan deskripsi operasi API konektor Amazon Redshift Python.

redshift_connector

Berikut ini, Anda dapat menemukan deskripsi operasi redshift_connector API.

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

Membuat koneksi ke cluster Amazon Redshift. Fungsi ini memvalidasi input pengguna, secara opsional mengautentikasi menggunakan plugin penyedia identitas, dan kemudian membangun objek koneksi.

apilevel

Level DBAPI didukung, saat ini “2.0".

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

Gaya parameter API database untuk digunakan secara global.

Koneksi

Berikut ini, Anda dapat menemukan deskripsi operasi API koneksi untuk konektor Amazon Redshift Python.

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

Menginisialisasi objek koneksi mentah.

cursor

Membuat objek kursor terikat pada koneksi ini.

commit

Melakukan transaksi database saat ini.

rollback

Menggulung kembali transaksi database saat ini.

close

Menutup koneksi database.

execute(cursor, operation, vals)

Menjalankan perintah SQL yang ditentukan. Anda dapat memberikan parameter sebagai urutan atau sebagai pemetaan, tergantung pada nilai. redshift_connector.paramstyle

run(sql[, stream])

Menjalankan perintah SQL yang ditentukan. Secara opsional, Anda dapat menyediakan aliran untuk digunakan dengan perintah COPY.

xid(format_id, global_transaction_id, …)

Buat ID transaksi. Hanya global_transaction_id parameter yang digunakan di postgres. format_id dan branch_qualifier tidak digunakan di postgres. global_transaction_idDapat berupa pengidentifikasi string apa pun yang didukung oleh postgres yang mengembalikan tuple (format_id,,global_transaction_id). branch_qualifier

tpc_begin(xid)

Memulai transaksi TPC dengan ID transaksi xid yang terdiri dari ID format, ID transaksi global, dan kualifikasi cabang.

tpc_prepare

Melakukan fase pertama transaksi yang dimulai dengan.tpc_begin.

tpc_commit([xid])

Ketika dipanggil tanpa argumen, .tpc_commit melakukan transaksi TPC yang sebelumnya disiapkan dengan.tpc_prepare ().

tpc_rollback([xid])

Ketika dipanggil tanpa argumen, .tpc_rollback mengembalikan transaksi TPC.

tpc_recover

Mengembalikan daftar transaksi tertunda yang IDs cocok untuk digunakan dengan.tpc_commit (xid) atau.tpc_rollback (xid).

Kursor

Berikut ini, Anda dapat menemukan deskripsi operasi API kursor.

__init__(connection[, paramstyle])

Menginisialisasi objek kursor mentah.

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

Menjalankan pernyataan INSERT massal.

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

Menjalankan operasi database.

executemany(operation, param_sets)

Mempersiapkan operasi database, dan kemudian menjalankannya untuk semua urutan parameter atau pemetaan yang disediakan.

fetchone

Mengambil baris berikutnya dari hasil kueri set.

fetchmany([num])

Mengambil set baris berikutnya dari hasil query.

fetchall

Mengambil semua baris yang tersisa dari hasil query.

close

Tutup kursor sekarang.

__iter__

Sebuah objek kursor dapat diiterasi untuk mengambil baris dari query.

fetch_dataframe([num])

Mengembalikan kerangka data dari hasil query terakhir.

write_dataframe(df, table)

Menulis kerangka data struktur yang sama ke dalam database Amazon Redshift.

fetch_numpy_array([num])

Mengembalikan NumPy array hasil query terakhir.

get_catalogs

Amazon Redshift tidak mendukung beberapa katalog dari satu koneksi. Amazon Redshift hanya mengembalikan katalog saat ini.

get_tables([catalog, schema_pattern, …])

Mengembalikan tabel publik unik yang ditentukan pengguna dalam sistem.

get_columns([catalog, schema_pattern, …])

Mengembalikan daftar semua kolom dalam tabel tertentu dalam database Amazon Redshift.

AdfsCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API AdfsCredentialsProvider plugin untuk konektor Amazon Redshift Python. 

redshift_connector.plugin.AdfsCredentialsProvider()

AzureCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API AzureCredentialsProvider plugin untuk konektor Amazon Redshift Python.

redshift_connector.plugin.AzureCredentialsProvider()

BrowserAzureCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API BrowserAzureCredentialsProvider plugin untuk konektor Amazon Redshift Python.

redshift_connector.plugin.BrowserAzureCredentialsProvider()

BrowserSamlCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API BrowserSamlCredentialsProvider plugin untuk konektor Amazon Redshift Python.

redshift_connector.plugin.BrowserSamlCredentialsProvider()

OktaCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API OktaCredentialsProvider plugin untuk konektor Amazon Redshift Python.

redshift_connector.plugin.OktaCredentialsProvider()

PingCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API PingCredentialsProvider plugin untuk konektor Amazon Redshift Python.

redshift_connector.plugin.PingCredentialsProvider()

SamlCredentialsProvider plugin

Berikut ini adalah sintaks untuk operasi API SamlCredentialsProvider plugin untuk konektor Amazon Redshift Python.

redshift_connector.plugin.SamlCredentialsProvider()