Function Compute:Kendi Yönetiminizdeki Apache RocketMQ Tetikleyicileri

Nasıl Çalışır?

Function Compute'da bir tetikleyici oluşturduğunuzda, Function Compute yapılandırmanıza dayanarak EventBridge içinde karşılık gelen olay akışı oluşturur. Tetikleyici ayrıntılarını Function Compute konsolunda ve otomatik olarak oluşturulan kaynakları EventBridge konsolunda görüntüleyebilirsiniz.

Ön Koşullar

Başlamadan önce şunlara sahip olduğunuzdan emin olun:

• Gerekli izinler verilmiş şekilde EventBridge etkinleştirilmiş olmalı

• Bir Function Compute işlevi oluşturulmuş olmalı

• Kullanılabilir ve erişilebilir durumda kendi yönetiminizdeki bir Apache RocketMQ kümesi dağıtılmış olmalı. Bir kümeyi hızla dağıtmak ve mesaj gönderip almaya başlamak için sürümünüzle ilgili hızlı başlangıç kılavuzuna bakın:

  • Apache RocketMQ 5.0: Hızlı BaşlangıçHızlı Başlangıç

  • Apache RocketMQ 4.x: Hızlı BaşlangıçHızlı Başlangıç

• RocketMQ örneğinizde bir konu oluşturulmuş olmalı

• RocketMQ örneğinizde bir tüketici grubu oluşturulmuş olmalı

Sınırlamalar

• RocketMQ örneğine genel internet üzerinden veya bir Alibaba Cloud Sanal Özel Bulut (VPC) üzerinden erişilebilir olması gerekir.

• Örneğe bir VPC üzerinden erişiliyorsa, VPC'nin işlevinizle aynı bölgede olması gerekir. Güvenlik grubunun RocketMQ NameServer bağlantı noktasında (varsayılan: 9876) gelen trafiğe izin verdiğinden emin olun.

• RocketMQ tetikleyicilerinin sayısı, EventBridge olay akışı kotasıyla sınırlıdır. Ayrıntılar için bkz. Sınırlamalar.

Adım 1: Tetikleyici Oluşturma

1. Function Compute konsoluna giriş yapın. Sol gezinme bölmesinde Functions öğesine tıklayın.

2. Üst gezinme çubuğunda bir bölge seçin. Functions sayfasında yönetmek istediğiniz işleve tıklayın.

3. İşlev ayrıntıları sayfasında Trigger sekmesine tıklayın, ardından Create Trigger düğmesine tıklayın.

4. Create Trigger panelinde aşağıdaki tabloda açıklanan parametreleri yapılandırın ve OK düğmesine tıklayın.

Gönderim yapılandırmaları, yeniden deneme ilkeleri ve dead-letter kuyrukları gibi gelişmiş ayarlar için bkz. Tetikleyicilerin Gelişmiş Özellikleri.

Tetikleyici oluşturulduktan sonra Triggers sekmesinde görünür. Tetikleyiciyi değiştirmek veya silmek için bkz. Tetikleyicileri Yönetme.

Adım 2: Test Olayını Yapılandırma

Tetikleyici, RocketMQ'dan gelen mesajları işlevinize olay nesnelerinden oluşan bir dizi olarak iletir. Manuel olarak bir test olayı yapılandırarak tetikleyici çağrısını simüle edin.

1. İşlev ayrıntıları sayfasının Code sekmesinde, Test Function yanındaki simgesine tıklayın ve Configure Test Parameters seçeneğini belirleyin.

2. Configure Test Parameters panelinde Create new test event veya Modify existing test event seçeneğini belirleyin. Bir olay adı girin, aşağıdaki olay içeriğini yapıştırın ve OK düğmesine tıklayın.

[
  {
    "msgId": "7F0000010BDD2A84AEE70DA49B57****",
    "topic": "testTopic",
    "systemProperties": {
      "UNIQ_KEY": "7F0000010BDD2A84AEE70DA49B57****",
      "CLUSTER": "DefaultCluster",
      "MIN_OFFSET": "0",
      "TAGS": "TagA",
      "MAX_OFFSET": "128"
    },
    "userProperties": {},
    "body": "Hello RocketMQ"
  }
]

Dizideki her nesne bir RocketMQ mesajını temsil eder. Alanlar aşağıda açıklanmıştır.

Adım 3: İşlev Kodunu Yazma ve Test Etme

Tetikleyici oluşturulduktan sonra gelen mesajları işlemek için işlev kodunuzu yazın. Üretim ortamında tetikleyici, RocketMQ yeni bir mesaj aldığında işlevi otomatik olarak çağırır.

1. İşlev ayrıntıları sayfasının Code sekmesinde kodunuzu düzenleyiciye yazın ve Deploy düğmesine tıklayın. Aşağıdaki Node.js örneği olayı okur ve bir sonuç döndürür:

   'use strict';
   /*
   To enable the initializer feature,
   implement the initializer function as shown below:
   exports.initializer = (context, callback) => {
     console.log('initializing');
     callback(null, '');
   };
   */
   exports.handler = (event, context, callback) => {
     console.log("event: %s", event);
     // Parse the event and process each message.
     callback(null, 'return result');
   }

2. Önceki adımda yapılandırdığınız test olayını çalıştırmak için Test Function düğmesine tıklayın.

Sonraki Adımlar

Function Compute konsoluna ek olarak tetikleyicileri şu araçlarla yapılandırıp yönetebilirsiniz:

• Serverless Devs: Bkz. Yaygın Serverless Devs Komutları

• SDK'lar: Bkz. SDK'lar

Mevcut bir tetikleyiciyi değiştirmek veya silmek için bkz. Tetikleyicileri Yönetme.