DataWorks:Node Function Compute

Batasan

• Batasan fitur

  DataWorks hanya mendukung pemanggilan event functions, bukan HTTP functions. Oleh karena itu, Anda harus menggunakan event function untuk tugas yang ingin dijadwalkan secara berkala. Untuk informasi selengkapnya tentang jenis fungsi, lihat Jenis fungsi.

• Batasan wilayah

  Fitur Function Compute hanya tersedia di ruang kerja yang berada di wilayah berikut: Tiongkok (Hangzhou), Tiongkok (Shanghai), Tiongkok (Beijing), Tiongkok (Shenzhen), Tiongkok (Chengdu), Tiongkok (Hong Kong), Singapura, Malaysia (Kuala Lumpur), Indonesia (Jakarta), Jerman (Frankfurt), Inggris (London), AS (Silicon Valley), dan AS (Virginia).

Catatan Penggunaan

• Jika daftar layanan kosong saat Anda mencoba memilih layanan, hal ini mungkin disebabkan oleh salah satu alasan berikut:

  • Akun Anda memiliki pembayaran tertunda. Isi ulang akun Anda dan muat ulang halaman konfigurasi node.

  • Pengguna yang sedang login tidak memiliki izin untuk mengambil daftar layanan. Hubungi pemilik Akun Alibaba Cloud Anda untuk memberikan izin fc:ListServices kepada Pengguna RAM Anda, atau menyambungkan kebijakan AliyunFCFullAccess. Setelah izin diberikan, muat ulang halaman konfigurasi node dan coba lagi. Untuk informasi selengkapnya tentang cara memberikan izin, lihat Berikan izin kepada Pengguna RAM.

• Untuk fungsi dalam node Function Compute DataWorks, jika waktu proses melebihi satu jam, Anda harus mengatur metode pemanggilan ke pemanggilan asinkron. Untuk informasi selengkapnya tentang pemanggilan asinkron di Function Compute, lihat Pemanggilan asinkron.

• Jika Anda menggunakan Pengguna RAM untuk mengembangkan node Function Compute, Anda harus memberikan izin kebijakan sistem atau kebijakan kustom berikut kepada pengguna tersebut.

  Jenis Kebijakan	Deskripsi
  Kebijakan sistem	Jika Anda menggunakan kebijakan sistem, berikan kebijakan AliyunFCFullAccess, AliyunFCReadOnlyAccess, dan AliyunFCInvocationAccess kepada pengguna.
  Kebijakan Kustom	Jika Anda menggunakan Function Compute kebijakan kustom, izin berikut umumnya diberikan: fc:GetAsyncTask fc:StopAsyncTask fc:GetService fc:ListServices fc:GetFunction fc:InvokeFunction fc:ListFunctions fc:GetFunctionAsyncInvokeConfig fc:ListServiceVersions fc:ListAliases fc:GetAlias fc:ListFunctionAsyncInvokeConfigs fc:GetStatefulAsyncInvocation fc:StopStatefulAsyncInvocation

  Catatan

  Untuk informasi selengkapnya tentang kebijakan izin Function Compute, lihat dokumen berikut:

  • Kebijakan dan contoh (Function Compute 2.0)

  • Kebijakan dan contoh (Function Compute 3.0)

Langkah 1: Buka halaman pembuatan node

1. Login ke Konsol DataWorks. Di wilayah target, klik Data Development and O&M > Data Development di panel navigasi kiri. Pilih ruang kerja dari daftar drop-down dan klik Go to Data Development.

2. Buka halaman pembuatan node.

   Di halaman DataStudio, Anda dapat membuat node Function Compute dengan salah satu dari tiga cara berikut. Metode 1: Di bilah menu atas, klik + New > Node > Function Compute. Metode 2: Di pohon proses bisnis di sebelah kiri, klik kanan proses bisnis target dan pilih New Node > Function Compute. Metode 3: Perluas proses bisnis target di sebelah kiri, klik General > New Node, lalu pilih Function Compute.

Langkah 2: Buat dan konfigurasikan node

1. Buat node Function Compute.

   Di halaman pembuatan node, konfigurasikan informasi dasar untuk node baru, seperti path dan nama, lalu buat node tersebut.

2. Konfigurasikan parameter untuk node Function Compute.

   Di halaman konfigurasi node, pilih fungsi yang akan dipanggil dan konfigurasikan metode pemanggilan serta variabelnya. Tabel berikut menjelaskan parameter-parameter tersebut.

   Parameter	Deskripsi
   Select Function	Pilih fungsi yang akan dipanggil untuk tugas ini. Jika tidak ada fungsi yang tersedia, Anda harus membuatnya terlebih dahulu. Untuk informasi selengkapnya, lihat Buat fungsi. Catatan DataWorks hanya mendukung pemanggilan event functions, bukan HTTP functions. Oleh karena itu, Anda harus menggunakan event function untuk tugas yang ingin dijadwalkan secara berkala. Untuk informasi selengkapnya tentang jenis fungsi, lihat Jenis fungsi. Dalam contoh ini, fungsi para_service_01_by_time_triggers dipilih. Saat membuat fungsi ini, pilih kode contoh untuk timer-triggered function yang disediakan oleh platform. Logika kodenya adalah sebagai berikut. import json import logging logger = logging.getLogger() def handler(event, context): logger.info('event: %s', event) # Parse the json evt = json.loads(event) triggerName = evt["triggerName"] triggerTime = evt["triggerTime"] payload = evt["payload"] logger.info('triggerName: %s', triggerName) logger.info("triggerTime: %s", triggerTime) logger.info("payload: %s", payload) return 'Timer Payload: ' + payload Untuk contoh kode fungsi lainnya, lihat Kode contoh.
   Select Version or Alias	Pilih versi layanan atau alias. Versi default adalah LATEST. Versi layanan Function Compute menyediakan fitur pengendalian versi di tingkat layanan yang memungkinkan Anda menerbitkan satu atau beberapa versi layanan Anda. Saat Anda menerbitkan versi, Function Compute membuat snapshot layanan, termasuk konfigurasinya, kode fungsi, dan konfigurasi fungsi. Pemicu tidak termasuk. Function Compute kemudian secara otomatis menetapkan nomor versi pada snapshot tersebut untuk digunakan di masa depan. Untuk informasi selengkapnya, lihat Terbitkan versi. Alias versi Function Compute memungkinkan Anda membuat alias untuk versi layanan. Alias mengarah ke versi tertentu, yang mempermudah operasi seperti penerbitan, rollback, dan rilis canary. Alias tidak dapat berdiri sendiri tanpa layanan atau versi. Saat Anda menggunakan alias untuk mengakses layanan atau fungsi, Function Compute menyelesaikan alias tersebut ke versi yang dituju. Pemanggil tidak perlu mengetahui versi spesifiknya. Untuk informasi selengkapnya, lihat Buat alias.
   Invocation Method	Metode pemanggilan berikut didukung: Synchronous invocation: Event langsung memicu fungsi. Function Compute menjalankan fungsi dan menunggu respons. Setelah fungsi dipanggil, Function Compute mengembalikan hasil eksekusi. Asynchronous invocation: Function Compute mengantri permintaan event dan segera mengembalikan respons, tanpa menunggu permintaan selesai. Jika fungsi memakan waktu lama, intensif sumber daya, atau berisi logika yang rentan error, Anda dapat menggunakan pemanggilan asinkron untuk meningkatkan kecepatan respons dan menangani lonjakan traffic secara andal. Untuk tugas Function Compute yang berjalan lebih dari satu jam, gunakan pemanggilan asinkron.
   Variable	Tetapkan nilai untuk variabel fungsi. Variabel ini sesuai dengan muatan event yang didefinisikan di bagian Test Function > Configure Test Event di Konsol Function Compute. Contoh ini meneruskan parameter berikut ke variabel dalam fungsi para_service_01_by_time_triggers. Dalam parameter tersebut, format ${} digunakan untuk mendefinisikan variabel bernama bizdate. Anda harus memberikan nilai untuk variabel ini di Langkah 4. { "payload": "payload1", "triggerTime": "${bizdate}", "triggerName": "triggerName1" }

3. Opsional. Debug dan jalankan node Function Compute.

   Setelah mengonfigurasi node, klik ikon . Anda kemudian dapat menentukan kelompok sumber daya untuk tugas tersebut dan memberikan nilai konstan ke variabel kode untuk menjalankan pengujian debugging dan memverifikasi logika node. Saat menjalankan pengujian, gunakan format key=value. Gunakan koma (,) untuk memisahkan beberapa parameter.

   Catatan

   Untuk informasi selengkapnya tentang cara melakukan debugging tugas, lihat Debug tugas.

4. Konfigurasikan properti penjadwalan untuk node.

   DataWorks menggunakan parameter penjadwalan untuk meneruskan nilai dinamis ke tugas terjadwal. Setelah mendefinisikan variabel seperti ${bizdate} dalam konfigurasi node, Anda harus memberikan nilainya di scheduling properties. Contoh ini menetapkan tanggal hari sebelumnya ke variabel bizdate. Artinya, DataWorks menjadwalkan node untuk berjalan satu hari sebelum waktu eksekusi yang dikonfigurasi. Untuk informasi selengkapnya tentang cara mengonfigurasi parameter penjadwalan, lihat Konfigurasi parameter penjadwalan. Klik tab scheduling properties di panel kanan. Di bagian scheduling parameters, tambahkan parameter secara manual. Tetapkan nama parameter ke bizdate dan nilai ke $[yyyymmdd-1]. Di bagian Variable editor kode di sebelah kiri, referensikan parameter penjadwalan ini dengan menggunakan ${bizdate}. Misalnya, tetapkan nilai bidang triggerTime ke ${bizdate}. Pilih LATEST untuk versi fungsi dan Synchronous untuk metode pemanggilan. Untuk informasi selengkapnya tentang properti penjadwalan node, lihat Konfigurasi properti dasar tugas.

Langkah 3: Commit dan deploy node

Untuk menjalankan node Function Compute sesuai jadwal otomatis, Anda harus terlebih dahulu melakukan commit dan menerapkannya ke lingkungan produksi.

1. Simpan dan commit node.

   Klik ikon dan di bilah alat untuk menyimpan dan melakukan commit node. Di kotak dialog commit, masukkan deskripsi perubahan dan, jika diperlukan, pilih opsi untuk tinjauan kode dan pengujian asap.

   Catatan

   • Anda harus mengonfigurasi properti Rerun attribute dan Parent Nodes di properti penjadwalan sebelum dapat melakukan commit node.

   • Jika tinjauan kode diaktifkan, kode node yang diajukan harus disetujui oleh reviewer sebelum node dapat diterapkan. Untuk informasi selengkapnya, lihat Tinjauan kode.

   • Untuk memastikan node terjadwal berjalan sesuai harapan, kami sarankan Anda melakukan pengujian asap pada tugas sebelum menerapkannya. Untuk informasi selengkapnya, lihat Pengujian asap.

2. Opsional. Deploy node.

   Jika Anda menggunakan ruang kerja dalam mode standar, Anda harus mengklik Deploy di pojok kanan atas untuk menerapkan node setelah melakukan commit. Untuk informasi selengkapnya, lihat Ruang kerja dalam mode standar dan Deploy tugas.