Model Studio SOP

Appearance

Configure HTTP callback or RocketMQ to receive asynchronous task results ​

Reference, synced 2026-06-13.

flowchart TD
  n0["Models"]
  n1["Overview"]
  n2["Products"]
  n3["Solutions"]
  n4["Pricing"]
  n5["Resources"]
  n6["Partners"]
  n7["Support"]
  n8["Language"]
  n0 --> n1
  n1 --> n2
  n2 --> n3
  n3 --> n4
  n4 --> n5
  n5 --> n6
  n6 --> n7
  n7 --> n8

Free access Accelerate Delivery with Fixed-Cost Agentic CodingWatch how it works

Models ​

Empowering AI innovation for both enterprises and developers with Alibaba Cloud’s best-in-class Qwen models, AI-native apps, and AI solutions.

Alibaba Cloud Model Studio \ Enterprise-grade large model service and application development platform.

Try Visual Model \ Supports image understanding, image generation, and video generation.

Models ​

HappyHorse-1.0-T2V \ Cinematic creative generation, ultimate dynamic details Qwen3-VL-Plus \ Native VL, spatial reasoning, 1M-context video analysis Wan2.7-VideoEdit \ Supports both localized and global editing with prompt

Qwen3.6-Plus \ Native multimodal, 1M context, agentic coding Wan2.7-Image-Pro \ Interactive editing, long-text rendering, precise prompt following Qwen-Plus \ Balanced intelligence, efficient inference, production-ready performance

Qwen-Image-2.0 \ Professional infographics, exquisite photorealism Z-Image-Turbo \ Ultra-fast image generation, high throughput, cost-optimized inference Qwen3-Coder-Next \ Multi-turn tool interactions, future-ready development support

Wan2.7-T2V \ High-fidelity T2V, 15s duration, advanced camera control Wan2.7-I2V \ Cinematic I2V with emotional depth and visceral impact Wan2.7-R2V \ Up to 5 mixed image/video inputs and audio timbre cloning

GenAI Application ​

Qoder \ Intelligent coding assistant, available for enterprise-dedicated deployment. Qoder CN \ AI-powered coding assistant that boosts developer productivity with intelligent code completion, AI chat, multi-file editing, and task automation.

AI Service ​

Model Experience \ Experience full-scale, multimodal model capabilities online. Platform for AI \ An AI-native algorithm engineering platform for end-to-end modeling, training, and inference service deployment. Fine-tune Video Generation Model \ Customize Wan’s text-to-video capabilities through model fine-tuning to meet your unique requirements.

AI Use Case ​

AI Savings Plan Hot \ Save up to 47% on AI costs. Limited-time offer tailored to your usage. AI Video Creation \ Elevate your professional video production with Wan 2.6.

AI Token Plan \ One plan. Multiple models. Big Savings with a Fixed Subscription. AI Image Creation \ All-in-one creative suite for copywriting, image generation, and poster design.

Overview ​

As a global full-stack AI leader, Alibaba Cloud aims to make computing accessible to everyone and help worldwide customers accelerate innovation.

Why Alibaba Cloud ​

About Alibaba Cloud \ AI Powered Cloud Technology Our Global Network \ Explore our global presence and deployment regions around the world Our Global Offices \ With offices in 4 continents, we're always close to where it matters.

Asia Accelerator \ Accelerate Success in Asia with Alibaba Cloud Go Global \ Benefits of our Global Alliance Trust Center \ Empowering enterprises with a secure, compliant, and globally trusted cloud infrastructure

Customers and Insights ​

Olympic Games \ Alibaba Cloud Powers Olympic Games with AI-powered cloud technology Case Studies \ Learn how customers are scaling their businesses on Alibaba Cloud Analyst Reports \ Learn what the top industry analyst firms are saying about Alibaba Cloud

What's New ​

Events and Webinars \ Quick access to upcoming and on-demand events Product Updates \ Stay informed of the latest innovations Press Room \ Latest news and media releases

Products ​

Featured ProductsAI & Machine Learning Computing Container Storage Networking & CDN Security Middleware Database Analytics ComputingMedia ServicesEnterprise Services & Cloud CommunicationDomain Names and WebsitesEnd User ComputingServerlessDeveloper ToolsMigration & O&M ManagementApsara Stack

Alibaba Cloud Model Studio \ Supercharge your AI journey effortlessly with industry-leading GenAI models ApsaraDB RDS \ Store and manage your business data, with automated monitoring and backups Certificate Management Service (Original SSL Certificate) \ Create a safe and secure connection between your website and users

Elastic Compute Service (ECS) \ Host websites anywhere and scale enterprise workloads Container Service for Kubernetes (ACK) \ Run and scale containerized applications on managed Kubernetes infrastructure Object Storage Service (OSS) \ Store large amounts of data in the cloud and access it anywhere, anytime

Simple Application Server (SAS) \ All-in-one services for fast deployment Elastic IP Address (EIP) \ Manage your public IPs independently to improve internet network quality Domain Names and Website \ Get the perfect domain name to suit your every need

Solutions ​

Solutions by Industry Technical Solutions AI WebsitesNetworking Security and ComplianceData and AnalyticsEnterprise Service and ApplicationCloud MigrationCloud NativeHybrid CloudSMB solutions

Financial Services \ Innovate faster with Alibaba Cloud Games \ Grow your game rapidly with high global availability

New Retail \ Alibaba Cloud enables digital retail transformation to fuel growth and realize an omnichannel customer experience throughout the consumer journey. Media and Entertainment \ Ready your content for today's media market with a digitalized media journey

Supply Chain \ Power your supply chain with intelligent, efficient, and reliable solutions Sports \ Digitizing the sports industry with intelligent tech

Sustainability \ Achieve a sustainable future with low-carbon and energy-efficient technologies

Pricing ​

Flexible options like pay-as-you-go and clear billing rules to meet diverse business needs.

Overview & Tools ​

Pricing Calculator \ Get an instant pricing estimate based on your usage and needs Free Trial \ Try our 80+ cloud products for free.

Pricing Options \ Get the most out of Alibaba Cloud with flexible pricing

Optimize your cost ​

Migrate & Save \ Superior Performance At Lower Pricing. Save up to 50%. Promotion Center \ Unlock the latest Alibaba Cloud offers & promos

Resources ​

Official documentation, extensive tools, training resources, and a community to grow and innovate in the cloud.

Technical Resources ​

Documentation \ Product guides and FAQs Architecture Center \ Design reliable, secure, and efficient cloud architecture. Intelligent Solution Explorer \ Find the right solution for you, powered by AI

Blog \ Latest cloud insights and developer trends Whitepapers \ Research that explores the how and why behind our technology

Training&Certification ​

Alibaba Cloud Academy \ Build cloud skills and earn certifications with expert-led training.

Developer Hub ​

Alibaba Cloud Project Hub \ Explore real-world projects built by developers using our platform. Our Developer MVPs \ Celebrating the developers who lead, build, and inspire our community

Partners ​

Partner-first strategy offering collaborative product, sales, and service models, plus high-quality partner solutions that complement Alibaba Cloud’s capabilities.

Marketplace ​

AI Alliance for ISVs \ Partner with us to build and grow AI solutions together ISV Benefits \ Unlock resources, market access, and go-to-market support as an ISV partner

Alibaba Cloud Marketplace \ Explore ready-to-deploy solutions from our partners and ISVs

Find a Partner ​

Partner Hub \ Find your ideal partner in no time

Become a Partner ​

Partner Network \ A partner portal for Alibaba Cloud Channel, Technology, MSP partner and other partner programs

Support ​

Full-lifecycle support and expert services, from cloud advisory and migration to operations.

Support & Professional Services ​

Professional Services \ Expert-led services to design, migrate, and optimize your cloud journey Support Plans \ Flexible support for every stage — from startup to enterprise

Partner Support Program \ Priority technical support for partners, with dedicated managers and faster issue resolution

Contact us ​

Connect With Us \

Talk to a sales expert and get a custom quote for your business

Language ​

  • English
  • 简体中文
  • 繁體中文
  • 日本語
  • Bahasa Indonesia

Locale ​

Visit aliyun.com

Documentation

Alibaba Cloud Model Studio

User Guide (Models) User Guide (Application) API Reference (Models) API Reference (Application)

Search for Help Content

Getting Started

The Beginner's Guide

Well-Architected Framework

AI & Machine Learning

Platform For AI

Alibaba Cloud Model Studio

DashVector

Artificial Intelligence Recommendation

OpenSearch

Image Search

Machine Translation

Intelligent Speech Interaction

Optimization Solver

Intelligent Computing LINGJUN

Computing

Elastic Compute Service

Elastic GPU Service

Elastic Container Instance

Dedicated Host

Compute Nest

Simple Application Server

Cloud Box

Auto Scaling

Elastic High Performance Computing

Batch Compute (Deprecated)

Function Compute

Serverless App Engine

ENS

Elastic Desktop Service

App Streaming

WUYING Terminal

Cloud Phone

Edge Network Acceleration

Alibaba Cloud Linux

AgentBay

Container

Container Service for Kubernetes

Container Compute Service

Container Registry

Storage

Object Storage Service

Cloud Parallel File Storage

File Storage NAS

Tablestore

Storage Capacity Unit

Simple Log Service

Cloud Backup

Intelligent Media Management

Drive and Photo Service

Data Transport

Cloud Storage Gateway

Data Online Migration

Hybrid Cloud Storage Array

Storage Services Overview

Backup and Disaster Recovery Center

Networking and CDN

Server Load Balancer

Elastic IP Address

Internet Shared Bandwidth

Data Transfer Plan

Virtual Private Cloud

NAT Gateway

PrivateLink

Alibaba Cloud DNS PrivateZone

Network Intelligence Service

Cloud Data Transfer

IPv6 Gateway

Anycast Elastic IP Address

Cloud Enterprise Network

Global Accelerator

VPN Gateway

Smart Access Gateway

Express Connect

CDN

Edge Security Acceleration

Cloud Network Well-architected Design Guidelines

Security

Anti-DDoS

Web Application Firewall

Cloud Firewall

Security Center

Bastionhost

Secure Access Service Edge

Certificate Management Service

Key Management Service

Data Security Center

Identity as a Service

Fraud Detection

AI Guardrails

Captcha

Blockchain as a Service

ID Verification

Managed Security Service

Middleware

Enterprise Distributed Application Service

Microservices Engine

Alibaba Cloud Service Mesh

SchedulerX

ApsaraMQ for RocketMQ

ApsaraMQ for Kafka

ApsaraMQ for RabbitMQ

ApsaraMQ for MQTT

Simple Message Queue (formerly MNS)

CloudFlow

EventBridge

Application Real-Time Monitoring Service

Managed Service for Prometheus

Managed Service for Grafana

Managed Service for OpenTelemetry

Performance Testing

STAROps

Databases

ApsaraDB Console

PolarDB

ApsaraDB RDS

ApsaraDB for OceanBase (Deprecated)

Tair (Redis® OSS-Compatible)

Lindorm

Time Series Database

ApsaraDB for MongoDB

ApsaraDB for HBase

ApsaraDB for Memcache

ApsaraDB for MyBase

AnalyticDB

ApsaraDB for ClickHouse

ApsaraDB for SelectDB

Data Transmission Service

Database Autonomy Service

Data Management

Database Gateway - Deprecated

ApsaraDB for Cassandra - Deprecated

Analytics Computing

MaxCompute

Hologres

Realtime Compute for Apache Flink

Elasticsearch

Vector Retrieval Service for Milvus

E-MapReduce

Data Lake Formation

DataV

Quick BI

Quick Audience

Quick Tracking

DataWorks

DataHub

Dataphin

Media Services

ApsaraVideo VOD

ApsaraVideo Live

Intelligent Media Services

ApsaraVideo Media Processing

Apsara Video SDK

Enterprise Services & Cloud Communication

Energy Expert

CloudQuotation

Salesforce on Alibaba Cloud

GoChina ICP Filing Assistant

Marketplace

Alibaba Mail

Direct Mail

Short Message Service

Voice Service

Phone Number Verification Service

Cell Phone Number Service

Chat App Message Service

Financial Intelligence Engine

Domain Names and Websites

Domain Names

ICP Filing

Alibaba Cloud DNS

End User Computing

Elastic Desktop Service

App Streaming

WUYING Terminal

Cloud Phone

AgentBay

Internet of Things

IoT Platform

Serverless

Serverless App Engine

CloudFlow

EventBridge

Simple Message Queue (formerly MNS)

Function Compute

Developer Tools

OpenAPI Explorer

Alibaba Cloud SDK

Cloud Shell

Resource Orchestration Service

Alibaba Cloud CLI

BSS OpenAPI

Terraform

Pulumi

Ticket System API

Mobile Platform as a Service

Alibaba Cloud DevOps

API Gateway

Cloud Control API

AI Coding Assistant Lingma

Cloud Skills Portal

Migration & O&M Management

CloudOps Orchestration Service

Cloud Monitor

Intelligent Advisor

Cloud Governance Center

ActionTrail

Cloud Config

Resource Access Management

Resource Management

Cloud Architect Design Tools

Migration Hub

Server Migration Center

Service Catalog

Logic Composer

Quota Center

CloudSSO

HTTPDNS

Solutions

SAP

SuperApp

OpenLake

Membership Service

Expenses and Costs

Account Center

More

Support

Legal

Tech Share Terms and Conditions

After Sales Support

China Gateway Program

Service Level Objectives

Management Console

Security Control

Instead of polling for task results, you can configure an HTTP callback URL or RocketMQ to receive task completion notifications from EventBridge. Once notified, query the result API once to get the output.

Background ​

Alibaba Cloud Model Studio integrates with EventBridge to deliver task completion events to your configured event targets.

When an asynchronous task finishes (success or failure), a task completion event containing the task status and ID is reported to EventBridge, which forwards it to your target. For more event targets, see Event targets and Target service types.

Polling vs. event-driven notifications

Comparison dimensionPollingEvent-driven
Comparison dimensionPollingEvent-driven
Rate limitingResult API is rate-limited (20 QPS)No rate limiting
Integration complexitySimple—poll the result API. Some tasks (such as text-to-image and text-to-video) provide SDKs with built-in polling.Configure HTTP callback or RocketMQ in EventBridge and parse notifications.
Server resource consumptionConsumes server resources with frequent queries.No resource consumption—EventBridge pushes to you.
LatencyDepends on polling interval.Near real-time—pushed immediately on completion.
RecommendationLow-concurrency or latency-tolerant scenarios.High-concurrency or latency-sensitive scenarios.

Configure one of the following event targets in EventBridge:

  • HTTP callback URL: A publicly accessible or VPC endpoint that accepts POST requests. Suitable for most scenarios.

  • RocketMQ: Consume events via Message Queue for RocketMQ. Ideal for high-reliability scenarios.

Option 1: Configure an HTTP callback URL ​

Overview ​

After Alibaba Cloud Model Studio completes a task, it reports the task completion event to EventBridge. EventBridge then pushes this event to your callback endpoint. Your callback endpoint parses the event to extract the successfully processed task ID and calls the result query API once to retrieve the task output.

Benefits: Compared to direct polling, this approach avoids unnecessary polling requests, reduces resource consumption, and lowers pressure on the result query API’s rate limits.

Billing: EventBridge billing.

For example, the asynchronous invocation flow using an HTTP callback URL for text-to-image is as follows: - Create a text-to-image task and receive a task_id. The task is not yet complete. - After Alibaba Cloud Model Studio finishes processing, it reports the task completion event to EventBridge. - EventBridge proactively pushes the event to the HTTP callback endpoint. - The callback endpoint parses the event to obtain the completed task_id. - Finally, call the result query API to get the generated image URL.

Procedure ​

Step 1: Prepare the HTTP callback endpoint

Typically, deploy the HTTP callback endpoint in your business system to receive asynchronous event notifications. It must meet these requirements:

  • Request URL: An HTTP URL accessible over the public network or an Alibaba Cloud VPC.

  • Request method: POST.

  • Request body: JSON format containing the asynchronous task completion event data. You can view the exact event structure in the EventBridge console. Example:

Click to view the data structure of the asynchronous task completion event

json
{
    "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-v1",
        "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"
}

Step 2: Query events in the EventBridge console ​

The EventBridge console lets you query events delivered by Alibaba Cloud Model Studio.

  1. Log on to your Alibaba Cloud account and go to the EventBridge console. Switch to the Singapore region. In the navigation pane on the left, select Event buses and click default to enter the default event bus for cloud services.

Alibaba Cloud Model Studio uses the default event bus by default.

  1. Click Event tracking and enter query conditions to find asynchronous task completion events from Alibaba Cloud Model Studio.

    • Event source: Search for and select acs.dashscope, indicating the event originates from DashScope (the underlying model service of Alibaba Cloud Model Studio).

    • Event type: Search for and select dashscope:System:AsyncTaskFinish, indicating an asynchronous task completion event.

  2. Click Details to view the full details of the reported event.
json
{
       "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-v1",
           "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"
}

Click to view parameter descriptions

ParameterTypeDescriptionExample value
datacontenttypeStringData format of the data field. Only application/json is supported.application/json;charset=utf-8
aliyunaccountidStringAlibaba Cloud account ID.123456789098****
aliyunpublishtimeStringTime when the event was received.2020-11-19T21:04:42.179PRC
dataObjectEvent content. A JSON object whose structure is defined by the originating service. CloudEvents may include contextual information provided by the event producer at the time of occurrence, encapsulated within data.
data[].start_timeStringAsynchronous task start time. Format: yyyy-MM-dd HH:mm:ss2023-10-25 09:45:09
data[].end_timeStringAsynchronous task completion time. Format: yyyy-MM-dd HH:mm:ss2023-10-25 09:45:16
data[].user_api_unique_keyStringUnique API key (the five elements of the model API used when submitting the task). Format: apikey:version:group:task:function-call:model - version: version - group: group - task: task name - function-call: method name - model: model nameapikey:v1:audio:asr:transcription:paraformer-8k-v1
data[].task_statusStringTask status - PENDING: queued - RUNNING: processing - SUCCEEDED: Processing succeeded. - FAILED: failed - CANCELED: Task canceled - UNKNOWN: task does not exist or status unknownSUCCEEDED
data[].task_idStringTask IDa154c328-xxxx-xxxx-xxxx-e52a9a7e9a35
data[].regionStringRegion where the task runsap-southeast-1
data[].request_idStringRequest ID108f38f5-xxxx-xxxx-xxxx-6504db9080b3
data[].api_key_idStringAPI key ID1234
aliyunoriginalaccountidStringOriginal Alibaba Cloud account ID123456789098****
specversionStringCloudEvents protocol version1.0
aliyuneventbusnameStringName of the event bus that receives the eventdefault
idStringEvent ID—a unique value identifying the event.45ef4dewdwe1-7c35-447a-bd93-fab****
sourceStringEvent source. The service that provides the event, identifying what occurred. It typically includes the event source type, publishing mechanism, or production process. The sender must ensure that each event’s source+id combination is unique.acs.dashscope
timeStringTime when the event was generated. If the exact event time is unknown, CloudEvents producers may set time to another value (e.g., current time), but all producers for the same source must use consistent values.2020-11-19T21:04:41+08:00
aliyunregionidStringRegion that receives the event.ap-southeast-1
typeStringEvent type. Describes the type of event related to the source. Used for routing, event queries, and policy enforcement. The format is defined by the producer and includes version information.dashscope:System:AsyncTaskFinish

Step 3: Configure event forwarding rules ​

  1. In the navigation pane on the left, select Event rules and click Create rule.

  2. Configure basic information: Enter a custom rule name and description.

  3. Configure event pattern: Specify which events to forward.

    • Event source: Search for and select acs.dashscope, indicating the event originates from Alibaba Cloud Model Studio.

    • Event type: Search for and select dashscope:System:AsyncTaskFinish, indicating an asynchronous task completion event.

    • Pattern content: Configure filter conditions to match specific events. Use fields from the event details queried in Step 2. For pattern syntax, see Event patterns. Examples:

      • Default: After selecting the event source and type, the pattern defaults to the following, forwarding all dashscope:System:AsyncTaskFinish events.
json
{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"]
}
 - Filter by field: Forward only events where the `user_api_unique_key` field ends with `:paraformer-8k-v1`—that is, only events for the `paraformer-8k-v1` model. Event type is `dashscope:System:AsyncTaskFinish`.
json
{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"],
  "data": {
    "user_api_unique_key": [\
      {"suffix": ":paraformer-8k-v1"}\
    ]
  }
}
  1. Configure event targets: Supports multiple event target types, including HTTP callback URLs and RocketMQ message queues. See Step 4 for details.

Step 4: Set the event target to an HTTP callback endpoint ​

  1. Configure event target: Forward events to an HTTP callback URL.

    • Service type: Select “HTTP”.

    • URL: Enter the HTTP service endpoint.

    • Body: Select “Complete event”.

    • Network type: Choose based on your service endpoint.

      • HTTP supports both public and private networks. If you select private network, configure VPC, vSwitch, and SecurityGroup.
  2. Click Confirm to save the rule. If the event target shows an HTTP style, the configuration succeeded.

The rule’s Event target column now displays HTTP (1).

Option 2: Configure RocketMQ ​

Overview ​

After Alibaba Cloud Model Studio completes a task, it reports the task completion event to EventBridge. EventBridge forwards the event to Message Queue for RocketMQ. Your application listens to the message queue, consumes the message, extracts the completed task ID, and calls the result query API once to retrieve the task output.

Benefits: Unlike the HTTP callback approach, RocketMQ guarantees message delivery and supports retry on failure—ideal for scenarios requiring high message reliability.

Billing: EventBridge billing, RocketMQ billing.

For example, the asynchronous invocation flow using RocketMQ for text-to-image is as follows: - Create a text-to-image task and receive a task_id. The task is not yet complete. - After Alibaba Cloud Model Studio finishes processing, it reports the task completion event to EventBridge. - EventBridge proactively forwards the event to the specified RocketMQ queue. - Your application listens to the RocketMQ queue, consumes the message, and extracts the completed task_id. - Finally, call the result query API to get the generated image URL.

Procedure ​

Step 1: Prepare a RocketMQ instance (skip if you already have a RocketMQ queue) ​

To receive events via RocketMQ, first prepare a RocketMQ queue.

  1. Go to the RocketMQ console. In the navigation pane on the left, select Instances and click Create Instance.

Instance ID example: rmq-cn-nwy*******.

  1. Create a Topic for the instance and enter a custom topic name.

  2. Create a Group for the instance and enter a custom group name.

Step 2: Query events in the EventBridge console ​

The EventBridge console lets you query events delivered by Alibaba Cloud Model Studio.

  1. Log on to your Alibaba Cloud account and go to the EventBridge console. Switch to the Singapore region. In the navigation pane on the left, select Event buses and click default to enter the default event bus for cloud services.

Alibaba Cloud Model Studio uses the default event bus by default.

  1. Click Event tracking and enter query conditions to find asynchronous task completion events from Alibaba Cloud Model Studio.

    • Event source: Search for and select acs.dashscope, indicating the event originates from DashScope (the underlying model service of Alibaba Cloud Model Studio).

    • Event type: Search for and select dashscope:System:AsyncTaskFinish, indicating an asynchronous task completion event.

  2. Click Details to view the full details of the reported event.
json
{
       "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-v1",
           "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"
}

Click to view parameter descriptions

ParameterTypeDescriptionExample value
datacontenttypeStringData format of the data field. Only application/json is supported.application/json;charset=utf-8
aliyunaccountidStringAlibaba Cloud account ID.123456789098****
aliyunpublishtimeStringTime when the event was received.2020-11-19T21:04:42.179PRC
dataObjectEvent content. A JSON object whose structure is defined by the originating service. CloudEvents may include contextual information provided by the event producer at the time of occurrence, encapsulated within data.
data[].start_timeStringAsynchronous task start time. Format: yyyy-MM-dd HH:mm:ss2023-10-25 09:45:09
data[].end_timeStringAsynchronous task completion time. Format: yyyy-MM-dd HH:mm:ss2023-10-25 09:45:16
data[].user_api_unique_keyStringUnique API key (the five elements of the model API used when submitting the task). Format: apikey:version:group:task:function-call:model - version: version - group: group - task: task name - function-call: method name - model: model nameapikey:v1:audio:asr:transcription:paraformer-8k-v1
data[].task_statusStringTask status - PENDING: queued - RUNNING: processing - SUCCEEDED: Processing succeeded. - FAILED: failed - CANCELED: Task canceled - UNKNOWN: task does not exist or status unknownSUCCEEDED
data[].task_idStringTask IDa154c328-xxxx-xxxx-xxxx-e52a9a7e9a35
data[].regionStringRegion where the task runsap-southeast-1
data[].request_idStringRequest ID108f38f5-xxxx-xxxx-xxxx-6504db9080b3
data[].api_key_idStringAPI key ID1234
aliyunoriginalaccountidStringOriginal Alibaba Cloud account ID123456789098****
specversionStringCloudEvents protocol version1.0
aliyuneventbusnameStringName of the event bus that receives the eventdefault
idStringEvent ID—a unique value identifying the event.45ef4dewdwe1-7c35-447a-bd93-fab****
sourceStringEvent source. The service that provides the event, identifying what occurred. It typically includes the event source type, publishing mechanism, or production process. The sender must ensure that each event’s source+id combination is unique.acs.dashscope
timeStringTime when the event was generated. If the exact event time is unknown, CloudEvents producers may set time to another value (e.g., current time), but all producers for the same source must use consistent values.2020-11-19T21:04:41+08:00
aliyunregionidStringRegion that receives the event.ap-southeast-1
typeStringEvent type. Describes the type of event related to the source. Used for routing, event queries, and policy enforcement. The format is defined by the producer and includes version information.dashscope:System:AsyncTaskFinish

Step 3: Configure event forwarding rules ​

  1. In the navigation pane on the left, select Event rules and click Create rule.

  2. Configure basic information: Enter a custom rule name and description.

  3. Configure event pattern: Specify which events to forward.

    • Event source: Search for and select acs.dashscope, indicating the event originates from Alibaba Cloud Model Studio.

    • Event type: Search for and select dashscope:System:AsyncTaskFinish, indicating an asynchronous task completion event.

    • Pattern content: Configure filter conditions to match specific events. Use fields from the event details queried in Step 2. For pattern syntax, see Event patterns. Examples:

      • Default: After selecting the event source and type, the pattern defaults to the following, forwarding all dashscope:System:AsyncTaskFinish events.
json
{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"]
}
 - Filter by field: Forward only events where the `user_api_unique_key` field ends with `:paraformer-8k-v1`—that is, only events for the `paraformer-8k-v1` model. Event type is `dashscope:System:AsyncTaskFinish`.
json
{
  "source": ["acs.dashscope"],
  "type": ["dashscope:System:AsyncTaskFinish"],
  "data": {
    "user_api_unique_key": [\
      {"suffix": ":paraformer-8k-v1"}\
    ]
  }
}
  1. Configure event targets: Supports multiple event target types, including HTTP callback URLs and RocketMQ message queues. See Step 4 for details.

Step 4: Set the event target to RocketMQ ​

After creating RocketMQ, open the event target configuration interface and select your RocketMQ instance.

  • Service type: Select “Message Queue for RocketMQ”.

  • Version: The RocketMQ version you created, such as RocketMQ 5.x.

  • Instance ID: The instance ID of your RocketMQ instance. See Step 1.

  • Topic: The topic name you created. See Step 1.

Step 5: View messages in the RocketMQ console ​

After configuration, submit an asynchronous task. Once complete, view the message in your configured RocketMQ topic.

  • To view messages online in RocketMQ, enable the one-click send/receive experience feature.

  • This feature uses Function Compute. If you exceed the free trial quota, minimal charges apply. See Function Compute billing rules.

On the Topics page, find your topic and click Details in the Actions column.

On the topic details page, switch to the One-click send/receive experience tab. In the Basic Features section, select a consumption method, such as PushConsumer.

After configuring parameters like Topic Name and Group ID, click Run to start receiving messages. The Run Results tab displays the received messages, including message ID and receipt time.

Step 6: Use the SDK to receive and consume messages ​

Use the RocketMQ Java SDK to implement the following logic: subscribe to the relevant topic and implement a message listener. Process the message upon receipt.

The following example shows Java client code for RocketMQ 5.0.

  • In a Maven project, add this dependency:
xml
<dependency>
  <groupId>org.apache.rocketmq</groupId>
  <artifactId>rocketmq-client-java</artifactId>
  <version>5.0.4</version>
</dependency>
  • Example code for consuming MQ messages:
java
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();
    }
}

FAQ ​

Can one event rule have multiple event targets? ​

Yes. A single event rule can have multiple event targets. If configured, the same event is delivered to every target.

I configured an event rule but am not receiving events. Why? ​

Ensure the event forwarding rule’s region matches the event’s region. For example, a rule configured in the Singapore region only forwards Singapore events—not other regions. Check the EventBridge region in the region selector at the top of the console page.

HTTP/HTTPS service request times out or returns an error? ​

Follow these steps to troubleshoot:

  1. Check the HTTP/HTTPS service status.

  2. Verify the URL configured in the event target.

  3. Check the network type configured for the event target:

    • PublicNetwork: Public network—ensure the URL is publicly accessible.

    • PrivateNetwork: VPC network—if selected, verify VPC, vSwitch, and SecurityGroup configurations.

      • Check VPC and vSwitch settings.

      • Check network security group settings.

  4. For other parameter settings, see Event target parameters.

Previous: Manage asynchronous tasksNext: Model calls in a sub-workspace

Is this page helpful?

Background

Option 1: Configure an HTTP callback URL

Overview

Procedure

Option 2: Configure RocketMQ

Overview

Procedure

FAQ

Can one event rule have multiple event targets?

I configured an event rule but am not receiving events. Why?

HTTP/HTTPS service request times out or returns an error?

Contact Us

Sales Support ​

Live-chat with our sales team or get in touch with a business development professional in your region.

Contact Sales

Technical Support ​

Open a ticket and get quick help from our technical team.

Open a Ticket >

Connect & Report Abuse ​

We look forward to your suggestion.

Post a Suggestion > Report Abuse >

\ \ Hi, I'm Alibaba Cloud AI Assistant!\ \ I can help with questions and solutions.

Why Alibaba Cloud

About Alibaba Cloud

Asia Accelerator

Our Global Network

Global Offices

Trust Center

Case Studies

Analyst Reports

Products & Pricings

Pricing Calculator

ECS

SAS

Model Studio

Database

Security

SMS

Solutions

Financial Services

Retail Services

Media Services

Gaming Services

ISV Solutions

Engage

Developer Community

Partner Network

Startups

Marketplace

Join Alibaba Cloud

Resources & Support

Developer Learning Hub

Documentation Center

Training & Certification

Service Notices

Submit a Ticket

Security Report

Qwen Cloud

Careers About Us Privacy Policy Legal Integrity Compliance Reporting Channel Service Notices Links

© 2009-2026 Copyright by Alibaba Cloud All rights reserved

© 2009-2026 Copyright by Alibaba Cloud All rights reserved

Careers About Us Privacy Policy Legal Integrity Compliance Reporting Channel Service Notices Links