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.
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 Secret AccessKey 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 Secret AccessKey yang memiliki izin yang diperlukan untuk mengoperasikan objek dalam proyek MaxCompute target. Anda dapat memperoleh kredensial ini dari halaman AccessKey Management.
your-default-project: Nama proyek MaxCompute Anda.
Login ke Konsol MaxCompute, lalu pilih wilayah di pojok kiri atas. Pada panel navigasi sebelah kiri, pilih .
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 tertentu. Untuk detail penggunaannya, lihat Contoh SDK Python: Tabel.