PyODPS adalah SDK Python untuk MaxCompute yang memungkinkan Anda mengembangkan tugas MaxCompute, menganalisis data, dan mengelola resource melalui Python.
PyODPS
PyODPS menyediakan API DataFrame dan metode untuk mengelola objek MaxCompute. SDK ini mendukung Python 2 (versi 2.6 ke atas) dan Python 3.
Pelajari lebih lanjut tentang PyODPS melalui sumber daya berikut:
-
Pelajari tentang PyODPS: Dokumentasi PyODPS dan Album Komunitas PyODPS.
-
Instal PyODPS: Panduan instalasi PyODPS.
-
Kembangkan dengan PyODPS: Panduan pengembangan PyODPS.
Inisialisasi client
Sebelum menggunakan PyODPS, inisialisasi objek client MaxCompute dengan kredensial Akun Alibaba Cloud Anda:
import os
from odps import ODPS
# Pastikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET
# telah diatur ke ID AccessKey dan AccessKey Secret Anda.
o = ODPS(
os.getenv('ALIBABA_CLOUD_ACCESS_KEY_ID'),
os.getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET'),
project='your-default-project',
endpoint='your-end-point',
)Parameter:
-
ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET: Atur variabel lingkungan ini ke ID AccessKey dan AccessKey Secret yang memiliki izin yang diperlukan untuk mengoperasikan objek dalam proyek MaxCompute target. Anda dapat memperoleh kredensial ini dari halaman manajemen AccessKey.
-
your-default-project: Nama proyek MaxCompute Anda. Anda dapat menemukan nama proyek tersebut di konsol MaxCompute melalui Workspace > Projects pada panel navigasi sebelah kiri.
-
your-end-point: Titik akhir untuk wilayah proyek tersebut.
Metode
Berikut adalah metode umum PyODPS untuk operasi MaxCompute:
|
Jenis objek |
Metode |
Deskripsi |
|
project |
get_project(project_name) |
Mengambil proyek MaxCompute. |
|
exist_project(project_name) |
Memeriksa apakah proyek MaxCompute ada. |
|
|
table |
list_tables() |
Menampilkan daftar semua tabel dalam proyek MaxCompute. |
|
exist_table(table_name) |
Memeriksa apakah tabel ada. |
|
|
get_table(table_name, project=project_name) |
Mengambil tabel. Akses lintas-proyek didukung. |
|
|
create_table() |
Membuat tabel. |
|
|
read_table() |
Membaca data dari tabel. |
|
|
write_table() |
Menulis data ke tabel. |
|
|
delete_table() |
Menghapus tabel. |
|
|
table partition |
exist_partition() |
Memeriksa apakah partisi tabel ada. |
|
get_partition() |
Mengambil partisi tabel. |
|
|
create_partition() |
Membuat partisi tabel. |
|
|
delete_partition() |
Menghapus partisi tabel. |
|
|
SQL statement |
execute_sql()/run_sql() |
Menjalankan pernyataan SQL. |
|
open_reader() |
Membaca hasil eksekusi. |
|
|
instance |
list_instances() |
Menampilkan daftar semua instans dalam proyek MaxCompute. |
|
exist_instance() |
Memeriksa apakah instans ada. |
|
|
get_instance() |
Mengambil instans. |
|
|
stop_instance() |
Menghentikan instans yang sedang berjalan. |
|
|
resource |
create_resource() |
Membuat resource. |
|
open_resource() |
Membuka resource untuk dibaca. |
|
|
get_resource() |
Mengambil resource. |
|
|
list_resources() |
Menampilkan daftar semua resource dalam proyek. |
|
|
exist_resource() |
Memeriksa apakah resource ada. |
|
|
delete_resource() |
Menghapus resource. |
|
|
function |
create_function() |
Membuat fungsi. |
|
delete_function() |
Menghapus fungsi. |
|
|
data tunnel |
create_upload_session() |
Membuat sesi unggah data. |
|
create_download_session() |
Membuat sesi unduh data. |
Metode create_table(), read_table(), write_table(), dan delete_table() memerlukan parameter. Untuk detail penggunaan, lihat Contoh SDK Python: Tabel.