Function Compute：Gunakan fungsi event untuk memproses event yang dihasilkan oleh layanan Alibaba Cloud

Skenario contoh

Pertimbangkan kebutuhan untuk menyimpan file yang tidak dikompresi di OSS sambil menerima unggahan ZIP untuk efisiensi transfer. Dalam hal ini, diperlukan proses otomatis untuk mendekompresi file dan menyimpannya kembali ke OSS.

Pendekatan konvensional akan memerlukan pembuatan dan integrasi beberapa program untuk memantau dan memproses perubahan file di OSS, sambil juga mempertimbangkan penyebaran dan pemeliharaan program-program tersebut. Sebaliknya, menggunakan fungsi event memungkinkan Anda fokus hanya pada logika dekompresi. Setiap kali file diunggah ke OSS, trigger event yang telah dikonfigurasi secara otomatis memanggil logika Anda jika event memenuhi kondisi yang ditentukan. Setelah pemrosesan, sumber daya komputasi dilepaskan secara otomatis, menghemat biaya.

Bagian berikut dari topik ini menunjukkan implementasi fungsi event.

Ini mensimulasikan event unggahan OSS yang memicu fungsi event untuk mendekompresi file, mencetak metadata file seperti nama dan informasi bucket di konsol Function Compute. Demo ini tidak bergantung pada sumber daya OSS aktual, sehingga Anda tidak perlu menyiapkan bucket OSS.

Berikut adalah item-item yang akan Anda pelajari dalam demo ini:

1. Menyelesaikan seluruh proses pembuatan fungsi event, menulis handler, dan menguji fungsi di konsol Function Compute.

2. Memahami konsep-konsep utama seperti lingkungan eksekusi Function Compute dan runtime bawaan.

3. Belajar tentang parameter permintaan event dan context di handler.

Prasyarat

Prosedur

# -*- coding: utf-8 -*-
import logging
import json
# import oss2  # Hapus komentar bagian ini jika Anda ingin membuat instance klien OSS.
logger = logging.getLogger()


def handler(event, context): # Handler berfungsi sebagai titik masuk untuk eksekusi kode.
    logger.info("Menguraikan informasi event...")
    input_events = json.loads(event)
    if not input_events.get('events'): # Periksa format event yang masuk.
        raise Exception("Format event tidak valid: array events hilang atau kosong")
    event_obj = input_events['events'][0]
    bucket_name = event_obj['oss']['bucket']['name']  # Uraikan nama bucket OSS.
    object_name = event_obj['oss']['object']['key']  # Uraikan nama file.
    region = context.region  # Uraikan wilayah tempat fungsi berada.
    logger.info(f"Bucket OSS: {bucket_name}, file: {object_name}, wilayah: {region}")
    # Jika Anda sudah memiliki bucket OSS, hapus komentar bagian berikut untuk membuat instance klien OSS.
    # bucket = get_bucket(region, bucket_name, context)
    bucket = None
    result = process_event(bucket, object_name)  # Panggil subroutine pemrosesan event.
    return result


def process_event(bucket, object_name):
    logger.info("Memulai pemrosesan event...")
    # Tambahkan logika di sini untuk pemrosesan event.
    # zip_file = download_file(bucket, object_name)
    # result = extract_and_upload(bucket, zip_file)
    logger.info("Pemrosesan event selesai")
    result = 0
    return result  # 0 menunjukkan pemrosesan event berhasil.


# def get_bucket(region, bucket_name, context):
#     # Buat instance klien bucket OSS. Informasi autentikasi yang diperlukan dapat diperoleh dari konteks.
#     creds = context.credentials  # Dapatkan Token Layanan Keamanan (STS).
#     auth = oss2.StsAuth(
#         creds.access_key_id,
#         creds.access_key_secret,
#         creds.security_token)
#     endpoint = f'oss-{region}-internal.aliyuncs.com'
#     bucket = oss2.Bucket(auth, endpoint, bucket_name)
#     return bucket


# def download_file(bucket, object_name):
#     # Contoh kode untuk mengunduh file dari OSS
#     try:
#         file_obj = bucket.get_object(object_name)
#         return file_obj
#     except oss2.exceptions.OssError as e:
#         logger.error(f"Unduhan file gagal: {e}")


# def extract_and_upload(bucket, file_obj):
#     # Tambahkan logika di sini untuk mendekompres file dan mengunggahnya ke OSS.
#     return 0;

'use strict';
// import OSSClient from 'ali-oss'; // Hapus komentar bagian ini jika Anda ingin membuat instance klien OSS.

export const handler = async (event, context) => { // Handler berfungsi sebagai titik masuk untuk eksekusi kode.
  console.log("Menguraikan informasi event...");
  const inputEvents = JSON.parse(event);
  if (!Array.isArray(inputEvents.events) || inputEvents.events.length === 0) { // Periksa format event yang masuk.
    throw new Error("Format event tidak valid: array events hilang atau kosong");
  }
  const eventObj = inputEvents.events[0];
  const bucketName = eventObj.oss.bucket.name; // Uraikan nama bucket OSS.
  const objectName = eventObj.oss.object.key; // Uraikan nama file.
  const region = context.region;  // Uraikan wilayah tempat fungsi berada.
  console.log(`Bucket OSS: ${bucketName}, objek: ${objectName}, wilayah: ${region}`);
  // Jika Anda sudah memiliki bucket OSS, hapus komentar bagian berikut untuk membuat instance klien OSS.
  // const bucket = getBucket(region, context)
  const bucket = null;
  const result = processEvent(bucket, objectName); // Panggil subroutine pemrosesan event.
  return result;
};


async function processEvent (bucket, objectName) {
  console.log("Memulai pemrosesan event...");
  // Tambahkan logika di sini untuk pemrosesan event.
  // const zipFile = downloadFile(bucket, objectName);
  // const result = extractAndUpload(bucket, zipFile);
  console.log("Pemrosesan event selesai");
  const result = 0;
  return result;
}


// function getBucket (region, context) {
//   // Buat instance klien bucket OSS. Informasi autentikasi yang diperlukan dapat diperoleh dari konteks.
//   const bucket = new OSSClient({
//     region: region,
//     accessKeyId: context.credentials.accessKeyId,
//     accessKeySecret: context.credentials.accessKeySecret,
//     securityToken: context.credentials.securityToken
//   });
//   return bucket;
// }


// async function downloadFile (bucket, objectName) {
//   try {
//     // Contoh kode untuk mengunduh file dari OSS
//     const result = await bucket.get(objectName, objectName);
//     console.log(result);
//     return result;
//   } catch (e) {
//     console.log(e);
//   }
// }

// async function extractAndUpload (bucket, zipFile) {
//     // Tambahkan logika di sini untuk mendekompres file dan mengunggahnya ke OSS.
//     return 0;
// }

Operasi lanjutan

Anda sekarang telah membuat fungsi event melalui Konsol Function Compute, mengonfigurasi handler fungsi, dan menguji fungsi menggunakan event simulasi event. Untuk konfigurasi lebih lanjut, lihat operasi lanjutan berikut berdasarkan kebutuhan bisnis Anda:

• Tambahkan Trigger:

  • Mengingat bahwa Anda mungkin belum memiliki bucket OSS, demo dalam topik ini menggunakan event OSS simulasi untuk pengujian, tanpa bergantung pada sumber daya OSS aktual. Namun, jika Anda ingin memproses event OSS nyata dalam bisnis Anda, Anda harus menambahkan trigger OSS untuk fungsi Anda. Untuk informasi lebih lanjut tentang menambahkan trigger, lihat Konfigurasikan Trigger OSS Asli.

  • Selain OSS, event dari berbagai layanan Alibaba Cloud lainnya (seperti layanan antrian pesan, Tablestore, dan Simple Log Service) juga dapat memicu eksekusi fungsi di Function Compute. Untuk informasi lebih lanjut tentang jenis trigger yang didukung oleh Function Compute, lihat Jenis Trigger.

• Tambahkan Dependensi: Meskipun dependensi umum untuk pemrosesan event sudah termasuk dalam setiap runtime bawaan Function Compute, mereka mungkin tidak memenuhi kebutuhan bisnis spesifik Anda. Dalam hal ini, solusi paling sederhana adalah mengemas kode Anda dan dependensi tambahan ke dalam file ZIP dan menyebarkannya ke Function Compute. Untuk langkah-langkah rinci, lihat Sebarkan Paket Kode. Jika Anda ingin mengurangi ukuran paket kode untuk mengurangi cold start fungsi, Anda dapat menggunakan layer untuk mengelola dependensi. Untuk informasi lebih lanjut, lihat Buat Layer Kustom.

• Konfigurasikan Logging: Untuk memudahkan debugging, pemecahan masalah, dan audit keamanan fungsi, kami merekomendasikan Anda mengonfigurasi fitur logging untuk fungsi Anda. Untuk langkah-langkah rinci, lihat Konfigurasikan Fitur Logging.

Referensi

• Selain menggunakan Konsol Function Compute untuk membuat fungsi, Anda juga dapat menggunakan Serverless Devs untuk melakukannya. Untuk informasi lebih lanjut, lihat Memulai Cepat.

• Kami merekomendasikan Anda merujuk pada tutorial praktis berikut untuk mempelajari lebih lanjut tentang fungsi event:

  • Gunakan Function Compute untuk Melakukan Pembersihan Pesan