Skema digunakan untuk mengaitkan proyek dengan tabel, sumber daya, dan fungsi di MaxCompute. Anda dapat menggunakan skema untuk mengklasifikasikan tabel, sumber daya, dan fungsi lebih lanjut. Topik ini menjelaskan operasi dasar pada skema.
Siapkan lingkungan runtime
PyODPS dapat berjalan pada node PyODPS di DataWorks atau pada mesin lokal. Sebelum menjalankan PyODPS, pilih alat yang sesuai dan siapkan lingkungan runtime.
DataWorks: Untuk menjalankan PyODPS di DataWorks, buat node PyODPS 2 atau node PyODPS 3. Untuk informasi lebih lanjut, lihat Gunakan PyODPS di DataWorks.
Mesin lokal: Untuk menjalankan PyODPS pada mesin lokal, instal PyODPS dan inisialisasi objek entri MaxCompute.
Lakukan operasi dasar
Untuk menggunakan fitur skema MaxCompute, aktifkan melalui Operasi terkait skema.
Buat skema.
schema = o.create_schema("**nama_skema**") print(schema)Hapus skema.
schema = o.delete_schema("**nama_skema**")Daftarkan semua skema.
for schema in o.list_schemas(): print(schema)Setelah mengaktifkan fitur skema, semua objek MaxCompute tempat objek entri MaxCompute dapat melakukan operasi berada dalam skema bernama
DEFAULT. Untuk melakukan operasi pada objek di skema lain, tentukan skema saat membuat objek entri. Contoh kode:# Setel variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID ke ID AccessKey Anda. # Setel variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_SECRET ke Rahasia AccessKey Anda. # Kami menyarankan agar Anda tidak langsung menggunakan ID AccessKey atau Rahasia AccessKey Anda. o = ODPS( os.getenv('ALIBABA_CLOUD_ACCESS_KEY_ID'), os.getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET'), project='<proyek-default-anda>', endpoint='<titik-akhir-anda>', schema='<nama-skema-anda>', )Tabel berikut menjelaskan parameter.
Parameter
Deskripsi
proyek-default-anda
Nama Proyek MaxCompute.
titik-akhir-anda
Titik akhir dari Proyek MaxCompute. Anda harus mengonfigurasi parameter ini berdasarkan wilayah dan metode koneksi jaringan yang Anda pilih saat membuat Proyek MaxCompute. Untuk informasi lebih lanjut tentang titik akhir yang sesuai dengan setiap wilayah dan jaringan, lihat Titik Akhir.
PentingJika Anda menentukan titik akhir yang tidak valid, kesalahan akan terjadi saat Anda mengakses MaxCompute.
nama-skema-anda
Nama skema.
Tentukan parameter
skemauntuk metode operasi objek yang berbeda. Contoh kode:# Daftarkan semua tabel dalam tabel test_schema. for table in o.list_tables(skema='**nama_skema**'): print(table)Tentukan skema default saat mengeksekusi pernyataan SQL. Contoh kode:
o.execute_sql("SELECT * FROM dual", skema_default="**nama_skema**")