Hologres:Fungsi yang Ditentukan Pengguna (Remote UDFs)

Ikhtisar fungsi

Fungsi remote memungkinkan Anda memperluas kemampuan pemrosesan dan analisis data dengan mengintegrasikan fungsi eksternal ke dalam Hologres. Di Hologres V3.1, fungsi remote mendukung pemanggilan ke layanan Alibaba Cloud Function Compute (FC). Fitur ini memungkinkan Anda memanggil FC secara dinamis untuk memproses logika bisnis kompleks atau melakukan operasi data lanjutan saat melakukan kueri terhadap data Hologres.

Fungsi remote mendukung tiga skenario berikut:

• Pemrosesan data real-time: Panggil fungsi eksternal secara real time selama kueri data untuk melakukan pembersihan data, konversi format, atau perhitungan kompleks.

• Integrasi layanan pihak ketiga: Gunakan Function Compute untuk berinteraksi dengan layanan Alibaba Cloud lainnya atau API pihak ketiga menggunakan data Hologres.

• Analitik lanjutan: Gunakan Function Compute untuk menerapkan algoritma analitik lanjutan, seperti inferensi model atau pembelajaran mesin, dan tulis hasilnya langsung ke Hologres.

Prasyarat

• Anda memiliki instans Hologres versi V3.1 atau lebih baru. Untuk informasi selengkapnya, lihat Beli instans Hologres.

• Anda telah mengaktifkan Function Compute, dan instans FC Anda adalah V3.0. Untuk melakukannya, login ke Function Compute console.

• Anda telah memberikan peran terkait layanan AliyunServiceRoleForHologresRemoteUDF.

  1. Masuk ke Konsol Hologres. Pada panel navigasi di sebelah kiri, klik Create a Service-linked Role.

  2. Pilih AliyunServiceRoleForHologresRemoteUDF dan klik Authorize Now. Gambar berikut menunjukkan contohnya.

     

Peringatan

• Hanya fungsi yang ditentukan pengguna skalar (UDF) dan fungsi bernilai tabel yang ditentukan pengguna (UDTF) yang didukung. Fungsi agregat yang ditentukan pengguna (UDAF) tidak didukung.

• Hanya tipe data berikut dan tipe array yang sesuai yang didukung: BOOLEAN, INTEGER, BIGINT, REAL, DOUBLE PRECISION, dan TEXT.

• Fungsi remote tidak mendukung konstanta sebagai parameter input.

• Fitur ini dikenai biaya di Function Compute (FC). Untuk informasi selengkapnya, lihat Penagihan.

• Fitur ini tidak dikenai biaya tambahan di Hologres.

Kelola fungsi yang ditentukan pengguna

CREATE EXTENSION [ IF NOT EXISTS ] function_compute;

CREATE [ OR REPLACE ] FUNCTION <function_name>
  ( [ [ argmode ] [ argname ] <argtype> [ { DEFAULT | = } default_expr ] [, ...] ] )
    [ RETURNS [SETOF] rettype | RETURNS TABLE ( column_name column_type) ]
  LANGUAGE function_compute
  AS '<fc_endpoint>/<func_name>'
  {
    { CALLED ON NULL INPUT | RETURNS NULL ON NULL INPUT | STRICT }
    | SET function_compute.qualifier TO <qualifier>
    | SET function_compute.compression TO <compression>
    | SET function_compute.max_batch_size TO <max_batch_size>
  } ...

SELECT
  CASE
    WHEN p.proretset = 'f' THEN 'scalar UDF'
    WHEN p.proretset = 't' THEN 'UDTF'
  END AS function_type,
  n.nspname AS schema_name,
  p.proname AS function_name,
  pg_get_function_arguments(p.oid) AS arguments,
  pg_get_function_result(p.oid) AS return_type,
  p.proisstrict AS is_strict,
  p.proconfig AS config,
  pg_get_functiondef(p.oid) AS definition
FROM
  pg_proc p
  JOIN pg_language l ON p.prolang = l.oid
  JOIN pg_namespace n ON p.pronamespace = n.oid
WHERE
  l.lanname = 'function_compute'
  AND p.prokind != 'p'
ORDER BY
  function_type,
  schema_name,
  function_name;

 DROP FUNCTION [ IF EXISTS ] <function_name> [ ( [ [ argmode ] [ argname ] <argtype> [, ...] ] ) ] [, ...]

DROP FUNCTION rf_add(INTEGER, INTEGER);

Format interaksi data

{  
  "data": [  
    ["foo", 100, true],
    [null, null, false],
    ["bar", 200, false]
  ]
}  

Contoh fungsi yang ditentukan pengguna

Contoh ini menggunakan fungsi unnest.

1. Aktifkan Function Compute.

   Login ke Function Compute console. Anda juga dapat mengklaim paket sumber daya gratis dengan kuota tertentu berdasarkan petunjuk di layar. Untuk informasi selengkapnya, lihat Kuota uji coba.

2. Buat fungsi event-triggered FC.

   1. Di panel navigasi sebelah kiri, klik Functions. Alihkan ke Wilayah tempat instans Hologres Anda berada.

   2. Di halaman Functions, klik Create Function. Anda kemudian akan diarahkan ke halaman Create Function.

   3. Pilih Event Function dan konfigurasikan parameter berikut. Anda dapat mempertahankan nilai default untuk parameter lainnya. Untuk informasi selengkapnya, lihat Buat fungsi event-triggered.

      Parameter	Deskripsi
      Nama Fungsi	Masukkan nama kustom. Misalnya, unnest.
      Runtime	Pilih Built-in Runtimes/Python/Python 3.10.
      Metode Unggah Kode	Pilih Upload Code via ZIP Package.
      Paket Kode	Unggah paket kode yang telah Anda tulis dan kemas. Simpan kode berikut ke file bernama unnest.py dan kompres menjadi unnest.zip. import json def unnest(event, context): evt = json.loads(event) data = evt.get('data', None) if data is None: raise ValueError('no "data" key in event.') if not isinstance(data, list): raise ValueError('data is not a list.') res = list() for i in range(len(data)): if len(data[i]) != 1 or not isinstance(data[i], list): raise ValueError('the item in data is not a list.') for item in data[i][0]: res.append([i, item]) return json.dumps({'results': res})
      Handler	Masukkan unnest.unnest.

3. Buat fungsi jarak jauh Hologres.

   Catatan

   Anda dapat menyelesaikan langkah-langkah berikut di platform HoloWeb. Untuk informasi selengkapnya, lihat Terhubung ke HoloWeb.

   CREATE EXTENSION IF NOT EXISTS function_compute;
   
   CREATE OR REPLACE FUNCTION rf_unnest(INTEGER [])
     RETURNS SETOF INTEGER
   STRICT
   LANGUAGE function_compute
   AS 'xxxxxxxxxxxxxxxxx.cn-shanghai-internal.fc.aliyuncs.com/unnest';

4. Siapkan data uji.

   CREATE TABLE test_array (
       numbers INTEGER[]
   );
   
   INSERT INTO test_array (numbers) VALUES
     (ARRAY[1, 3]),
     (ARRAY[2, 4]),
     ('{}'),  
     (ARRAY[]::INTEGER[]),  
     (NULL);

5. Panggil fungsi jarak jauh.

   SELECT numbers, rf_unnest(numbers) FROM test_array;
   
    numbers | rf_unnest
   ---------+-----------
    {2,4}   |         2
    {2,4}   |         4
    {1,3}   |         1
    {1,3}   |         3
   (4 rows)