全部产品
Search
文档中心

MaxCompute:Skema

更新时间:Jul 02, 2025

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.

    Penting

    Jika Anda menentukan titik akhir yang tidak valid, kesalahan akan terjadi saat Anda mengakses MaxCompute.

    nama-skema-anda

    Nama skema.

  • Tentukan parameter skema untuk 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**")