Alibaba Cloud Model Studio:Recevoir des notifications de fin de tâche via callback HTTP ou MQ

{
    "datacontenttype": "application/json;charset=utf-8",
    "aliyunaccountid": "xxxxx",
    "aliyunpublishtime": "2023-10-25T01:45:16.993Z",
    "data": {
        "start_time": "2023-10-25 09:45:09",
        "user_api_unique_key": "apikey:v1:audio:asr:transcription:paraformer-8k-v2",
        "task_status": "SUCCEEDED",
        "contain_result": false,
        "end_time": "2023-10-25 09:45:16",
        "task_id": "a154c328-xxxx-xxxx-xxxx-e52a9a7e9a35",
        "region": "cn-beijing",
        "request_id": "108f38f5-xxxx-xxxx-xxxx-6504db9080b3",
        "api_key_id": "1250"
    },
    "aliyunoriginalaccountid": "xxxxxxxx",
    "specversion": "1.0",
    "aliyuneventbusname": "default",
    "id": "81765e5b-xxxx-xxxx-xxxx-bbad8dde2bd9",
    "source": "acs.dashscope",
    "time": "2023-1-25T01:45:16.969Z",
    "aliyunregionid": "cn-beijing",
    "type": "dashscope:System:AsyncTaskFinish"
}

{
    "datacontenttype": "application/json;charset=utf-8",
    "aliyunaccountid": "xxxxx",
    "aliyunpublishtime": "2023-10-25T01:45:16.993Z",
    "data": {
        "start_time": "2023-10-25 09:45:09",
        "user_api_unique_key": "apikey:v1:audio:asr:transcription:paraformer-8k-v2",
        "task_status": "SUCCEEDED",
        "contain_result": false,
        "end_time": "2023-10-25 09:45:16",
        "task_id": "a154c328-xxxx-xxxx-xxxx-e52a9a7e9a35",
        "region": "ap-southeast-1",
        "request_id": "108f38f5-xxxx-xxxx-xxxx-6504db9080b3",
        "api_key_id": "1250"
    },
    "aliyunoriginalaccountid": "xxxxxxxx",
    "specversion": "1.0",
    "aliyuneventbusname": "default",
    "id": "81765e5b-xxxx-xxxx-xxxx-bbad8dde2bd9",
    "source": "acs.dashscope",
    "time": "2023-1-25T01:45:16.969Z",
    "aliyunregionid": "ap-southeast-1",
    "type": "dashscope:System:AsyncTaskFinish"
}

Pour recevoir des événements via RocketMQ, préparez d'abord une file d'attente RocketMQ.

1. Accédez à la console RocketMQ. Dans le volet de navigation de gauche, sélectionnez Instances et cliquez sur Create Instance.

   Exemple d'ID d'instance : rmq-cn-nwy*******.

2. Créez un Topic pour l'instance et saisissez un nom de topic personnalisé.

3. Créez un Group pour l'instance et saisissez un nom de groupe personnalisé.

La console EventBridge permet d'interroger les événements transmis par Alibaba Cloud Model Studio.

1. Connectez-vous à votre compte Alibaba Cloud et accédez à la console EventBridge. Basculez vers la Singapore region. Dans le volet de navigation de gauche, sélectionnez Event buses et cliquez sur default pour accéder au bus d'événements par défaut des services cloud.

   Par défaut, Alibaba Cloud Model Studio utilise le bus d'événements par défaut.

2. Cliquez sur Event tracking et saisissez les critères de recherche pour trouver les événements de fin de tâche asynchrone provenant d'Alibaba Cloud Model Studio.

   • Source de l'événement : recherchez et sélectionnez acs.dashscope, ce qui indique que l'événement provient de DashScope (le service de modèle sous-jacent d'Alibaba Cloud Model Studio).
   • Type d'événement : recherchez et sélectionnez dashscope:System:AsyncTaskFinish, correspondant à un événement de fin de tâche asynchrone.

3. Cliquez sur Details pour afficher tous les détails de l'événement signalé.

   {
       "datacontenttype": "application/json;charset=utf-8",
       "aliyunaccountid": "xxxxx",
       "aliyunpublishtime": "2023-10-25T01:45:16.993Z",
       "data": {
           "start_time": "2023-10-25 09:45:09",
           "user_api_unique_key": "apikey:v1:audio:asr:transcription:paraformer-8k-v2",
           "task_status": "SUCCEEDED",
           "contain_result": false,
           "end_time": "2023-10-25 09:45:16",
           "task_id": "a154c328-xxxx-xxxx-xxxx-e52a9a7e9a35",
           "region": "cn-beijing",
           "request_id": "108f38f5-xxxx-xxxx-xxxx-6504db9080b3",
           "api_key_id": "1250"
       },
       "aliyunoriginalaccountid": "xxxxxxxx",
       "specversion": "1.0",
       "aliyuneventbusname": "default",
       "id": "81765e5b-xxxx-xxxx-xxxx-bbad8dde2bd9",
       "source": "acs.dashscope",
       "time": "2023-1-25T01:45:16.969Z",
       "aliyunregionid": "cn-beijing",
       "type": "dashscope:System:AsyncTaskFinish"
   }
   

   {
       "datacontenttype": "application/json;charset=utf-8",
       "aliyunaccountid": "xxxxx",
       "aliyunpublishtime": "2023-10-25T01:45:16.993Z",
       "data": {
           "start_time": "2023-10-25 09:45:09",
           "user_api_unique_key": "apikey:v1:audio:asr:transcription:paraformer-8k-v2",
           "task_status": "SUCCEEDED",
           "contain_result": false,
           "end_time": "2023-10-25 09:45:16",
           "task_id": "a154c328-xxxx-xxxx-xxxx-e52a9a7e9a35",
           "region": "ap-southeast-1",
           "request_id": "108f38f5-xxxx-xxxx-xxxx-6504db9080b3",
           "api_key_id": "1250"
       },
       "aliyunoriginalaccountid": "xxxxxxxx",
       "specversion": "1.0",
       "aliyuneventbusname": "default",
       "id": "81765e5b-xxxx-xxxx-xxxx-bbad8dde2bd9",
       "source": "acs.dashscope",
       "time": "2023-1-25T01:45:16.969Z",
       "aliyunregionid": "ap-southeast-1",
       "type": "dashscope:System:AsyncTaskFinish"
   }
   

1. Dans le volet de navigation de gauche, sélectionnez Event rules et cliquez sur Create rule.

2. Configure basic information : saisissez un nom et une description personnalisés pour la règle.

3. Configure event pattern : spécifiez les événements à transférer.

   • Event source : recherchez et sélectionnez acs.dashscope, indiquant que l'événement provient d'Alibaba Cloud Model Studio.

   • Event type : recherchez et sélectionnez dashscope:System:AsyncTaskFinish, correspondant à un événement de fin de tâche asynchrone.

   • Pattern content : configurez les conditions de filtrage pour cibler des événements spécifiques. Utilisez les champs issus des détails d'événements interrogés à l'étape 2. Pour la syntaxe des modèles, consultez Modèles d'événements. Exemples :

     • Par défaut : après avoir sélectionné la source et le type d'événement, le modèle prend par défaut la forme suivante, transférant ainsi tous les événements dashscope:System:AsyncTaskFinish.

     {
       "source": ["acs.dashscope"],
       "type": ["dashscope:System:AsyncTaskFinish"]
     }
     

     • Filtrage par champ : transférez uniquement les événements dont le champ user_api_unique_key se termine par :paraformer-8k-v2, c'est-à-dire uniquement les événements concernant le modèle paraformer-8k-v2. Le type d'événement est dashscope:System:AsyncTaskFinish.

     {
       "source": ["acs.dashscope"],
       "type": ["dashscope:System:AsyncTaskFinish"],
       "data": {
         "user_api_unique_key": [
           {"suffix": ":paraformer-8k-v2"}
         ]
       }
     }
     

4. Configure event targets : prend en charge plusieurs types de cibles d'événements, notamment les URL de callback HTTP et les files d'attente de messages RocketMQ. Consultez l'étape 4 pour plus de détails.

Après avoir créé RocketMQ, ouvrez l'interface de configuration de la cible d'événement et sélectionnez votre instance RocketMQ.

• Type de service : sélectionnez « Message Queue for RocketMQ ».
• Version : la version RocketMQ que vous avez créée, par exemple RocketMQ 5.x.
• Instance ID : l'ID de votre instance RocketMQ. Consultez l'Étape 1.
• Topic : le nom du topic que vous avez créé. Consultez l'Étape 1.

Après la configuration, soumettez une tâche asynchrone. Une fois celle-ci terminée, consultez le message dans le topic RocketMQ configuré.

• Pour afficher les messages en ligne dans RocketMQ, activez la fonctionnalité d'expérience d'envoi/réception en un clic.
• Cette fonctionnalité utilise Function Compute. Si vous dépassez le quota d'essai gratuit, des frais minimes s'appliquent. Consultez les Règles de facturation de Function Compute.

Sur la page Topics, localisez votre topic et cliquez sur Details dans la colonne Actions.

Sur la page de détails du topic, basculez vers l'onglet One-click send/receive experience. Dans la section Basic Features, sélectionnez une méthode de consommation, telle que PushConsumer.

Après avoir configuré des paramètres tels que Topic Name et Group ID, cliquez sur Run pour commencer à recevoir des messages. L'onglet Run Results affiche les messages reçus, y compris l'ID du message et l'heure de réception.

Utilisez le SDK Java RocketMQ pour mettre en œuvre la logique suivante : abonnez-vous au topic concerné et implémentez un écouteur de messages. Traitez le message dès sa réception.

L'exemple suivant présente le code client Java pour RocketMQ 5.0.

• Dans un projet Maven, ajoutez cette dépendance :

<dependency>
  <groupId>org.apache.rocketmq</groupId>
  <artifactId>rocketmq-client-java</artifactId>
  <version>5.0.4</version>
</dependency>

• Exemple de code pour consommer des messages MQ :

import com.alibaba.fastjson2.JSON;
import org.apache.rocketmq.client.apis.*;
import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
import org.apache.rocketmq.client.apis.consumer.FilterExpression;
import org.apache.rocketmq.client.apis.consumer.FilterExpressionType;
import org.apache.rocketmq.client.apis.consumer.PushConsumer;
import org.apache.rocketmq.shaded.org.slf4j.Logger;
import org.apache.rocketmq.shaded.org.slf4j.LoggerFactory;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Collections;

public class ConsumerExample {
    private static final Logger LOGGER = LoggerFactory.getLogger(ConsumerExample.class);

    private ConsumerExample() {
    }

    public static void main(String[] args) throws ClientException, IOException, InterruptedException {
        /*
          Endpoint obtained from the Endpoints tab on the instance details page in the console.
          If accessing from an Alibaba Cloud ECS instance over the internal network, use the VPC endpoint.
          If accessing from a local public network or on-premises IDC, use the public endpoint. Public endpoint access requires enabling public network access for the instance.
         */
        String endpoints = "xxxx";
        // Specify the target topic to subscribe to. The topic must be created in the console beforehand; otherwise, an error occurs.
        String topic = "xxxx";
        // Specify the consumer group for the consumer. The group must be created in the console beforehand; otherwise, an error occurs.
        String consumerGroup = "xxxx";
        final ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfigurationBuilder builder = ClientConfiguration.newBuilder().setEndpoints(endpoints);
        /*
          If using a public endpoint, configure the instance username and password, available on the instance details page in the console.
          If accessing from an Alibaba Cloud ECS instance over the internal network, skip this configuration—the server intelligently retrieves VPC info.
         */
        builder.setCredentialProvider(new StaticSessionCredentialsProvider("xxxx", "xxxx"));
        ClientConfiguration clientConfiguration = builder.build();
        // Subscription filter rule—subscribe to messages with any tag.
        String tag = "*";
        FilterExpression filterExpression = new FilterExpression(tag, FilterExpressionType.TAG);
        // Initialize PushConsumer with consumer group, communication parameters, and subscription relationship.
        PushConsumer pushConsumer = provider.newPushConsumerBuilder()
        .setClientConfiguration(clientConfiguration)
        // Set consumer group.
        .setConsumerGroup(consumerGroup)
        // Set pre-bound subscription relationships.
        .setSubscriptionExpressions(Collections.singletonMap(topic, filterExpression))
        // Set message listener.
        .setMessageListener(messageView -> {
            try {
                // Process message and return consumption result.
                ByteBuffer buffer = messageView.getBody();
                ByteBuffer newBuffer = ByteBuffer.allocate(buffer.capacity());
                for (int i = 0; i < buffer.capacity(); i++) {
                    newBuffer.put(buffer.get(i));
                }
                String result = new String(newBuffer.array());
                LOGGER.info("Consume message={}", JSON.toJSONString(result));
                System.out.println(result);
                return ConsumeResult.SUCCESS;
            } catch (Exception e) {
                LOGGER.error("deal message has error", e);
                return ConsumeResult.FAILURE;
            }
        })
        .build();
        Thread.sleep(Long.MAX_VALUE);

        // Close PushConsumer when no longer needed.
        pushConsumer.close();
    }
}