Function Compute:RocketMQ tetikleyicileri

Nasıl çalışır?

Function Compute konsolunda tetikleyici oluşturma isteği gönderdiğinizde Function Compute, tetikleyici yapılandırmasına göre EventBridge'de otomatik olarak bir Olay akışı kaynağı oluşturur.

Tetikleyiciyi oluşturduktan sonra Function Compute konsolunda tetikleyici bilgilerini ve EventBridge konsolunda otomatik olarak oluşturulan kaynakları görüntüleyebilirsiniz. Kaynak ApsaraMQ for RocketMQ örneğine bir mesaj kuyruğa alındığında Function Compute çağrılır. Her çağrı sırasında toplu iş yapılandırmanıza bağlı olarak bir veya daha fazla mesaj olayı toplu halde işleve gönderilir. Bu davranış uçtan uca akış veri işleme senaryolarına uygundur.

Kullanım notları

• Olay kaynağı olarak kullanılan ApsaraMQ for RocketMQ örneği Function Compute işleviyle aynı bölgede bulunmalıdır.

• Oluşturulan olay akışı sayısı üst sınırı aşarsa artık RocketMQ tetikleyicisi oluşturamazsınız.

Tek bir Alibaba Cloud hesabında ve tek bir bölgede tetikleyici oluşturmak için kullanılan kaynak sayısının sınırları hakkında bilgi edinmek için bkz. Sınırlar.

Ön koşullar

• EventBridge

  • EventBridge'i etkinleştirin ve bir RAM kullanıcısına izin verin

• Function Compute

  • Bir olay işlevi oluşturun

• ApsaraMQ for RocketMQ

  • ApsaraMQ for RocketMQ'yu etkinleştirin ve izin verin

  • Bir örnek, konu ve grup kimliği oluşturun

Adım 1: Tetikleyici oluşturma

1. Function Compute konsoluna oturum açın, yönetmek istediğiniz işlevi bulun, ardından işlev ayrıntıları sayfasında Trigger sekmesine tıklayın ve Create Trigger seçeneğine tıklayın.

2. Tetikleyici Oluştur panelinde Trigger Type değerini ApsaraMQ for RocketMQ olarak ayarlayın, aşağıdaki tabloda açıklanan parametreleri yapılandırın ve ardından OK seçeneğine tıklayın.

Gönderim yapılandırması, yeniden deneme ilkeleri ve dead-letter queues gibi gelişmiş ayarlar hakkında bilgi edinmek için bkz. Tetikleyicilerin gelişmiş özellikleri.

Adım 2: (İsteğe bağlı) İşlev giriş parametrelerini yapılandırma

ApsaraMQ for RocketMQ olay kaynağı işleve bir event giriş parametresi olarak iletilir. event parametresini ayrıştırmak ve işlemek için kodunuzu kullanın. Tetikleyici olayını simüle etmek ve işlev kodunun doğru olup olmadığını kontrol etmek amacıyla işleve manuel olarak bir event aktarabilirsiniz.

1. İşlev ayrıntıları sayfasının Code sekmesinde Test Function öğesinin yanındaki simgesine tıklayın ve açılan listeden 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ı ve olay içeriği girin ve ardından Tamam'a tıklayın.

event biçimi aşağıdaki gibidir.

[
    {
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"RocketMQ-Function-rocketmq-trigger",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunaccountid":"164901546557****",
    "aliyunpublishtime":"2021-10-15T02:05:16.791Z",
    "aliyunoriginalaccountid":"164901546557****",
    "aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
    "aliyunregionid":"cn-chengdu",
    "aliyunpublishaddr":"42.120.XX.XX",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
        },
        "userProperties":{

        },
        "body":"TEST"
    }
    },
    {
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"RocketMQ-Function-rocketmq-trigger",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunaccountid":"164901546557****",
    "aliyunpublishtime":"2021-10-15T02:05:16.791Z",
    "aliyunoriginalaccountid":"164901546557****",
    "aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
    "aliyunregionid":"cn-chengdu",
    "aliyunpublishaddr":"42.120.XX.XX",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
        },
        "userProperties":{

        },
        "body":"TEST"
    }
    }
]

Aşağıdaki tabloda data alanında bulunan parametreler açıklanmaktadır. CloudEvents belirtiminde tanımlanan parametreler hakkında bilgi edinmek için bkz. Genel Bakış.

Adım 3: İşlev kodunu yazma ve test etme

Tetikleyiciyi oluşturduktan sonra kodun doğru olduğunu doğrulamak için işlev kodunu yazın ve test edin. Pratikte bir ApsaraMQ for RocketMQ olayı EventBridge aracılığıyla Function Compute'e iletildiğinde tetikleyici işlevi otomatik olarak çağırır.

1. İşlev ayrıntıları sayfasının Code sekmesinde kod düzenleyicide kodunuzu yazın ve ardından Deploy seçeneğine tıklayın.

   Bu konuda Node.js işlev kodu örnek olarak kullanılmıştır.

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

2. İşlevi test edin.

   Yöntem 1: Olay kaynağını simüle etmek için event işlev giriş parametresini yapılandırdıysanız Test Function seçeneğine tıklayın.

   Yöntem 2: ApsaraMQ for RocketMQ konsoluna oturum açın, kullanmak istediğiniz ApsaraMQ for RocketMQ örneğinin konusunu bulun, Message Send/Receive Test seçeneğine tıklayın ve ardından talimatlara göre bir mesaj gönderin.

3. Çalıştırma tamamlandıktan sonra işlev ayrıntıları sayfasının Code sekmesinde sonucu görüntülemek için Real-time Logs seçeneğine tıklayın.