Alibaba Cloud Model Studio:Recibir notificaciones de finalización de tareas mediante callback HTTP o MQ

Normalmente, implemente el endpoint de callback HTTP en su sistema empresarial para recibir notificaciones de eventos asíncronos. Debe cumplir estos requisitos:

• URL de solicitud: Una URL HTTP accesible a través de la red pública o una VPC de Alibaba Cloud.
• Método de solicitud: POST.
• Cuerpo de la solicitud: formato JSON que contiene los datos del evento de finalización de tarea asíncrona. Puede ver la estructura exacta del evento en la consola de EventBridge. Ejemplo:

{
    "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"
}

La consola de EventBridge le permite consultar eventos entregados por Alibaba Cloud Model Studio.

1. Inicie sesión en su cuenta de Alibaba Cloud y vaya a la consola de EventBridge. Cambie a la región de Singapore. En el panel de navegación izquierdo, seleccione Event buses y haga clic en default para ingresar al bus de eventos predeterminado para servicios en la nube.

   Alibaba Cloud Model Studio utiliza el bus de eventos predeterminado por defecto.

2. Haga clic en Event tracking e introduzca condiciones de consulta para encontrar eventos de finalización de tareas asíncronas de Alibaba Cloud Model Studio.

   • Origen del evento: Busque y seleccione acs.dashscope, lo que indica que el evento se origina en DashScope (el servicio de modelos subyacente de Alibaba Cloud Model Studio).
   • Tipo de evento: Busque y seleccione dashscope:System:AsyncTaskFinish, lo que indica un evento de finalización de tarea asíncrona.

3. Haga clic en Details para ver todos los detalles del evento reportado.

{
    "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. En el panel de navegación izquierdo, seleccione Event rules y haga clic en Create rule.

2. Configurar información básica: Introduzca un nombre y una descripción personalizados para la regla.

3. Configurar patrón de eventos: Especifique qué eventos reenviar.

   • Origen del evento: Busque y seleccione acs.dashscope, lo que indica que el evento se origina en Alibaba Cloud Model Studio.

   • Tipo de evento: Busque y seleccione dashscope:System:AsyncTaskFinish, lo que indica un evento de finalización de tarea asíncrona.

   • Contenido del patrón: Configure condiciones de filtro para coincidir con eventos específicos. Utilice los campos de los detalles del evento consultados en el Paso 2. Para la sintaxis de patrones, consulte Patrones de eventos. Ejemplos:

     • Predeterminado: Después de seleccionar el origen y el tipo de evento, el patrón toma el siguiente valor predeterminado, reenviando todos los eventos dashscope:System:AsyncTaskFinish.

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

• Filtrar por campo: Reenviar solo eventos donde el campo user_api_unique_key termine con :paraformer-8k-v2, es decir, solo eventos para el modelo paraformer-8k-v2. El tipo de evento es dashscope:System:AsyncTaskFinish.

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

4. Configurar destinos de eventos: Admite múltiples tipos de destino de evento, incluidas URLs de callback HTTP y colas de mensajes RocketMQ. Consulte el Paso 4 para más detalles.

1. Configurar destino del evento: Reenviar eventos a una URL de callback HTTP.

   • Tipo de servicio: Seleccione “HTTP”.

   • URL: Introduzca el endpoint del servicio HTTP.

   • Cuerpo: Seleccione “Complete event”.

   • Tipo de red: Elija según su endpoint de servicio.

     • HTTP admite redes públicas y privadas. Si selecciona red privada, configure VPC, vSwitch y SecurityGroup.

2. Haga clic en Confirm para guardar la regla. Si el destino del evento muestra un estilo HTTP, la configuración fue exitosa.

   La columna Destino del evento de la regla ahora muestra HTTP (1).

Para recibir eventos mediante RocketMQ, primero prepare una cola de RocketMQ.

1. Vaya a la consola de RocketMQ. En el panel de navegación izquierdo, seleccione Instances y haga clic en Create Instance.

   Ejemplo de ID de instancia: rmq-cn-nwy*******.

2. Cree un Topic para la instancia e introduzca un nombre de tema personalizado.

3. Cree un Group para la instancia e introduzca un nombre de grupo personalizado.

La consola de EventBridge le permite consultar eventos entregados por Alibaba Cloud Model Studio.

1. Inicie sesión en su cuenta de Alibaba Cloud y vaya a la consola de EventBridge. Cambie a la región de Singapore. En el panel de navegación izquierdo, seleccione Event buses y haga clic en default para ingresar al bus de eventos predeterminado para servicios en la nube.

   Alibaba Cloud Model Studio utiliza el bus de eventos predeterminado por defecto.

2. Haga clic en Event tracking e introduzca condiciones de consulta para encontrar eventos de finalización de tareas asíncronas de Alibaba Cloud Model Studio.

   • Origen del evento: Busque y seleccione acs.dashscope, lo que indica que el evento se origina en DashScope (el servicio de modelos subyacente de Alibaba Cloud Model Studio).
   • Tipo de evento: Busque y seleccione dashscope:System:AsyncTaskFinish, lo que indica un evento de finalización de tarea asíncrona.

3. Haga clic en Details para ver todos los detalles del evento reportado.

{
    "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. En el panel de navegación izquierdo, seleccione Event rules y haga clic en Create rule.

2. Configurar información básica: Introduzca un nombre y una descripción personalizados para la regla.

3. Configurar patrón de eventos: Especifique qué eventos reenviar.

   • Origen del evento: Busque y seleccione acs.dashscope, lo que indica que el evento se origina en Alibaba Cloud Model Studio.

   • Tipo de evento: Busque y seleccione dashscope:System:AsyncTaskFinish, lo que indica un evento de finalización de tarea asíncrona.

   • Contenido del patrón: Configure condiciones de filtro para coincidir con eventos específicos. Utilice los campos de los detalles del evento consultados en el Paso 2. Para la sintaxis de patrones, consulte Patrones de eventos. Ejemplos:

     • Predeterminado: Después de seleccionar el origen y el tipo de evento, el patrón toma el siguiente valor predeterminado, reenviando todos los eventos dashscope:System:AsyncTaskFinish.

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

• Filtrar por campo: Reenviar solo eventos donde el campo user_api_unique_key termine con :paraformer-8k-v2, es decir, solo eventos para el modelo paraformer-8k-v2. El tipo de evento es dashscope:System:AsyncTaskFinish.

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

4. Configurar destinos de eventos: Admite múltiples tipos de destino de evento, incluidas URLs de callback HTTP y colas de mensajes RocketMQ. Consulte el Paso 4 para más detalles.

Después de crear RocketMQ, abra la interfaz de configuración del destino del evento y seleccione su instancia de RocketMQ.

• Tipo de servicio: Seleccione “Message Queue for RocketMQ”.
• Versión: La versión de RocketMQ que creó, como RocketMQ 5.x.
• Instance ID: El ID de instancia de su instancia de RocketMQ. Consulte Paso 1.
• Topic: El nombre del tema que creó. Consulte Paso 1.

Después de la configuración, envíe una tarea asíncrona. Una vez completada, vea el mensaje en su tema de RocketMQ configurado.

• Para ver mensajes en línea en RocketMQ, habilite la función de experiencia de envío/recepción con un clic.
• Esta función utiliza Function Compute. Si supera la cuota de prueba gratuita, se aplicarán cargos mínimos. Consulte las Reglas de facturación de Function Compute.

En la página Topics, busque su tema y haga clic en Details en la columna Actions.

En la página de detalles del tema, cambie a la pestaña One-click send/receive experience. En la sección Basic Features, seleccione un método de consumo, como PushConsumer.

Después de configurar parámetros como Topic Name y Group ID, haga clic en Run para comenzar a recibir mensajes. La pestaña Run Results muestra los mensajes recibidos, incluido el ID del mensaje y la hora de recepción.

Utilice el SDK de Java de RocketMQ para implementar la siguiente lógica: suscribirse al tema relevante e implementar un listener de mensajes. Procese el mensaje al recibirlo.

El siguiente ejemplo muestra código de cliente Java para RocketMQ 5.0.

• En un proyecto Maven, agregue esta dependencia:

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

• Código de ejemplo para consumir mensajes de 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();
    }
}