阿里云智能决策平台对接使用完全指南:从架构解析到生产级集成实战
一、阿里云智能决策平台概述
阿里云智能决策平台并非单一产品,而是一个覆盖数据采集、数据治理、AI建模、风险决策、智能分析到大模型应用的全链路决策智能体系。该平台整合了DataWorks、Quick BI、PAI、决策引擎、百炼大模型等多个核心产品,为企业提供从数据到决策的一站式解决方案。
决策引擎平台基于阿里自研风控实时计算引擎,历经多年电商、媒体、交易等场景实战,是一站式实时规则策略计算平台。决策引擎在原阿里自用风控引擎基础上,提供个性化业务场景事件管理、可视化编排复杂决策、丰富的特征变量与场景识别服务等功能。相较于需要开发背景及算法背景才能使用的传统风控引擎,阿里云决策引擎无需开发背景甚至无需算法建模背景,就可以将大数据与人工智能算法应用到业务智能决策中。
优化求解器产品是求解优化问题的专业设计软件,技术来自达摩院决策智能实验室的MindOpt Solver,可广泛应用于云计算、电力能源、工业制造、交通物流、零售、金融等领域。Quick BI则是一款全场景消费式的BI产品,服务于有数据化转型和提升智能决策和分析能力诉求的企业。DataWorks作为一站式大数据开发治理平台,提供数据集成、数据开发、数据治理、数据分析和数据服务等全链路数据开发能力。
需要先登录阿里云控制台,点击:阿里云控制台
二、平台核心架构与组件解析
阿里云智能决策平台的架构可划分为五个核心层次:
2.1 数据接入层
支持OSS、MaxCompute、RDS等多种数据源对接,通过可视化界面配置数据字段映射。平台还内置了隐私保护引擎,可自动识别身份证、银行卡等敏感信息,确保符合GDPR等合规要求。
2.2 数据开发与治理层
以DataWorks为核心,提供数据集成、数据开发、数据治理、数据分析和数据服务等全链路能力。DataWorks深度集成MaxCompute、EMR、Hologres、Flink等主流计算引擎,支持跨引擎协同开发。
2.3 AI模型层
以PAI人工智能平台为核心,提供模型训练、部署与推理服务。PAI EAS(模型在线服务)支持将训练好的模型快速部署为在线服务,通过API对外提供推理能力。
2.4 决策与风控层
包含决策引擎(风险决策平台)和优化求解器(运筹优化引擎)。决策引擎用于复杂风控策略设计与编排,满足实时风险识别与检测的规则计算需求。优化求解器则提供数学规划求解能力。
2.5 智能分析与应用层
包含Quick BI(智能数据分析与可视化)、百炼大模型平台(大模型应用开发)以及各类智能体应用。百炼智能体支持通过API调用,也支持一键发布到第三方平台。
三、DataWorks数据开发治理平台对接
3.1 环境准备:工作空间创建与计算资源绑定
工作空间是DataWorks中进行任务开发和成员权限管理的基本单元。登录DataWorks控制台,在左上角切换至目标地域,单击左侧导航栏中的"工作空间列表",进入空间列表页面后单击"创建工作空间"。
在创建页面完成以下关键配置:
- 工作空间名称:输入一个唯一且符合团队规范的名称
- 生产、开发环境隔离:建议开启,创建标准模式工作空间,确保开发与生产环境隔离
- 使用新版数据开发(Data Studio):推荐开启
执行创建操作的账号需为阿里云主账号,或已授予AliyunDataWorksFullAccess等权限策略的RAM用户。DataWorks工作空间分为简单模式与标准模式:标准模式提供独立的开发与生产环境,是保障数据安全和流程规范的最佳选择。
创建工作空间后,需要绑定计算资源才能进行任务开发。以MaxCompute为例,需要新建两个MaxCompute项目分别绑定到开发环境和生产环境。
3.2 数据源配置:对接各类数据源
使用DataWorks的数据集成、数据开发或数据分析功能前,需要先在DataWorks中添加数据源。登录DataWorks控制台,进入工作空间后,在左侧导航栏中选择"数据源",单击"新增数据源"。
DataWorks支持的数据源类型包括:
- 对象存储:OSS
- 大数据计算:MaxCompute、EMR
- 关系型数据库:RDS(MySQL、PostgreSQL、SQL Server等)
- 实时计算:Flink
- 数据仓库:Hologres、AnalyticDB
3.3 数据集成:离线与实时同步
DataWorks的数据集成模块支持离线批量同步和实时增量同步两种模式。以下是一个将RDS MySQL数据同步到MaxCompute的JSON配置示例:
{
"type": "job",
"version": "2.0",
"steps": [
{
"stepType": "mysql",
"parameter": {
"connection": [
{
"datasource": "mysql_datasource",
"table": ["source_table"]
}
],
"column": ["id", "name", "created_at"],
"where": "created_at >= '2026-01-01'"
},
"name": "Reader",
"category": "reader"
},
{
"stepType": "odps",
"parameter": {
"partition": "dt=${bizdate}",
"truncate": true,
"datasource": "odps_datasource",
"column": ["id", "name", "created_at"],
"table": "target_table"
},
"name": "Writer",
"category": "writer"
}
],
"setting": {
"errorLimit": {
"record": 0
},
"speed": {
"concurrent": 2,
"throttle": false
}
}
}3.4 数据开发:SQL任务与工作流编排
DataWorks的数据开发模块支持SQL、Shell、Python等多种任务类型。在Data Studio中,用户可以编写MaxCompute SQL、Hologres SQL等代码,通过调度配置实现任务的有序执行。
以下是一个MaxCompute SQL任务的示例:
-- 创建分区表
CREATE TABLE IF NOT EXISTS sales_summary (
product_id STRING COMMENT '商品ID',
category STRING COMMENT '商品类目',
total_sales DOUBLE COMMENT '总销售额',
order_count BIGINT COMMENT '订单数'
) PARTITIONED BY (dt STRING COMMENT '日期分区');
-- 插入数据
INSERT OVERWRITE TABLE sales_summary PARTITION (dt='${bizdate}')
SELECT
product_id,
category,
SUM(amount) AS total_sales,
COUNT(order_id) AS order_count
FROM orders
WHERE dt = '${bizdate}'
GROUP BY product_id, category;四、Quick BI智能数据分析与可视化工具对接
4.1 平台概述
Quick BI是一款全场景消费式的BI产品,服务于有数据化转型和提升智能决策和分析能力诉求的企业。Quick BI支持智能小Q(Intelligent Q)功能,通过大模型驱动实现"一句话提问、获取完整报告"的智能分析体验。
4.2 数据源接入
Quick BI支持接入多种数据源,包括MaxCompute、RDS、AnalyticDB、OSS等。在Quick BI控制台中,选择"数据源",单击"新建数据源",根据向导完成数据源配置。
以MaxCompute为例,需要配置以下信息:
- 项目名称:MaxCompute项目名称
- AccessKey ID和AccessKey Secret:用于身份认证
- Endpoint:MaxCompute服务接入地址
连接MaxCompute需要具备MaxCompute项目的CreateInstance、List和表的Desc权限;若需要上传文件,还需要拥有项目的CreateTable、Write权限。
4.3 报表与仪表板创建
接入数据源后,可以在Quick BI中创建数据集、仪表板和电子表格。Quick BI提供了丰富的可视化组件,包括柱状图、折线图、饼图、地图、表格等,用户可以通过拖拽式操作快速构建数据分析看板。
4.4 嵌入式集成:将报表嵌入自有系统
对于已经拥有业务系统的企业而言,将Quick BI的报表能力无缝嵌入到自有系统中,是实现数据驱动决策的关键步骤。Quick BI支持两种嵌入方式:
- 仪表板嵌入:通过iframe将单个仪表板嵌入到自有页面中
- 作品嵌入:通过OpenAPI获取嵌入Token,实现批量作品的统一管理
以下是获取嵌入Token的API调用示例:
POST /api/v1/embed/token HTTP/1.1
Host: quickbi.aliyuncs.com
Content-Type: application/json
Authorization: acs ${AccessKeyId}:${Signature}
{
"WorksId": "dashboard_12345",
"ExpireTime": 3600,
"GlobalParam": "{\"region\":\"华东\"}"
}4.5 OpenAPI自动化管理
Quick BI提供了丰富的OpenAPI,支持报表管理、数据集管理、用户管理等自动化操作。通过OpenAPI,企业可以实现BI能力的自动化运维和深度集成。
五、PAI人工智能平台对接
5.1 平台概述
PAI(Platform of Artificial Intelligence)是阿里云的人工智能平台,提供模型训练、部署与推理服务。PAI支持多种深度学习框架,包括TensorFlow、PyTorch、MXNet等,并提供了可视化建模、自动机器学习(AutoML)等高级功能。
5.2 模型训练
在PAI平台上进行模型训练,主要有三种方式:
- 可视化建模(PAI-Studio):通过拖拽式操作构建机器学习流程
- 分布式训练(PAI-DLC):支持大规模分布式训练,适用于深度学习场景
- 交互式建模(PAI-DSW):提供Jupyter Notebook环境,支持代码开发和调试
以下是一个使用PAI Python SDK提交训练任务的示例:
from alibabacloud_pai.client import PAIClient
from alibabacloud_pai.models import TrainingJob
client = PAIClient(
region_id='cn-hangzhou',
access_key_id='YOUR_ACCESS_KEY',
access_key_secret='YOUR_ACCESS_SECRET'
)
job = TrainingJob(
name='bert-classifier-training',
framework='tensorflow',
framework_version='2.9.0',
code_uri='oss://bucket/code/train.py',
data_uri='oss://bucket/data/train.csv',
output_uri='oss://bucket/output/',
resource_config={
'instance_type': 'ecs.gn6i-c4g1.xlarge',
'instance_count': 4
},
hyperparameters={
'epochs': 10,
'batch_size': 32,
'learning_rate': 0.001
}
)
result = client.create_training_job(job)
print(f'Job ID: {result.job_id}')5.3 模型部署:PAI EAS在线服务
PAI EAS(Elastic Algorithm Service)支持将训练好的模型快速部署为在线服务,通过API对外提供推理能力。部署EAS服务时,需要指定模型存储路径、资源规格和副本数量。
在PAI控制台的EAS页面,单击"部署服务",完成以下配置:
- 服务名称:输入服务名称
- 模型路径:选择已训练好的模型文件所在OSS路径
- 资源规格:选择CPU或GPU实例规格
- 副本数:设置服务实例数量,支持弹性伸缩
部署完成后,在EAS页面点击"查看调用信息"即可获取服务的endpoint和token信息。
以下是一个调用PAI EAS在线服务的Python示例:
import requests
import json
url = "https:///predict"
headers = {
"Authorization": "Bearer ",
"Content-Type": "application/json"
}
data = {
"instances": [
{
"feature1": 1.2,
"feature2": 3.4,
"feature3": 5.6
}
]
}
response = requests.post(url, headers=headers, json=data)
print(json.loads(response.text)) 六、决策引擎风险决策平台对接
6.1 平台概述
决策引擎是阿里云风险识别为全行业客户提供的综合风险决策平台。您可以在决策引擎中使用已成熟实践的风险策略,或自定义策略,解决包括注册、登录、营销、交易等环节的复杂问题。无需具备专业的风控知识,甚至无需算法建模背景,就可以将大数据与人工智能算法应用到业务智能决策中。
6.2 事件定义
事件是业务场景的抽象定义,用于定义入参数据结构。每个事件有相应的事件编码,当调用决策引擎时,传入事件编码,决策引擎会将不同的事件请求路由到对应的策略集合中进行计算并返回结果。
在决策引擎控制台中,通过定义业务场景来建立事件,并在该事件下设定和运营一整套风控策略。常见的事件类型包括:
- 注册事件:用于新用户注册场景的风险识别
- 登录事件:用于用户登录场景的风险识别
- 营销事件:用于营销活动场景的风险识别
- 交易事件:用于支付交易场景的风险识别
6.3 策略配置
策略是具体的运算逻辑,当事件数据请求进入决策引擎时,系统会根据配置的策略进行运算并返回结果。决策引擎提供了可视化的策略编排界面,支持:
- 规则配置:基于特征变量设置if-then规则
- 策略流编排:通过可视化节点拖拽构建复杂决策流程
- 策略测试:在沙箱环境中验证策略效果
6.4 事件接入与API调用
接入事件信息的方式与风险识别的API接入方式一致。其中公共参数中service参数的值为saf_de,ServiceParameters参数列表为JSON格式。
以下是一个调用决策引擎API的示例:
POST /api/v1/decision HTTP/1.1
Host: saf.aliyuncs.com
Content-Type: application/json
Authorization: acs ${AccessKeyId}:${Signature}
X-Acs-Version: 2019-05-21
X-Acs-Action: ExecuteDecision
{
"Service": "saf_de",
"ServiceParameters": {
"eventCode": "register_risk",
"accountId": "user_12345",
"mobileMd5": "e10adc3949ba59abbe56e057f20f883e",
"ip": "192.168.1.100",
"email": "user@example.com",
"operateTime": "2026-07-12 12:00:00",
"deviceToken": "encrypted_device_token_string"
}
}决策引擎还集成了阿里云内容安全文本审核增强版服务,您可通过决策引擎直接使用内容安全服务,降低对接成本。当前决策引擎服务集成了2项常用的内容安全文本审核服务。如果您购买了风险识别包年包月的商品,无需任何配置,可以直接通过API调用内容安全文本审核服务。调用方式为将公共参数中的service替换为内容安全文本审核的service。
七、百炼大模型平台对接
7.1 平台概述
阿里云百炼是大模型应用开发平台,提供专业领域知识管理、模型训练与模型微调、智能体搭建、能力评测等一站式服务工具链。百炼专属版是面向政企客户打造,支持国产算力、跨模态的行业大模型与智能体平台。
7.2 数据源对接
登录百炼控制台,在「数据管理」模块接入企业数据源,支持OSS、MaxCompute、RDS等数据源。通过可视化界面配置数据字段映射。启用内置的隐私保护引擎可自动识别身份证、银行卡等敏感信息,确保符合GDPR等合规要求。
7.3 模型选择与训练
调用百炼API创建训练任务。优先使用预置行业模型(如金融风控、零售分析),可减少70%训练时间。百炼支持以下模型类型:
- 通义千问系列:qwen-max、qwen-plus、qwen-turbo
- 行业专属模型:金融风控、零售分析、法律文书等
- 开源模型:Llama、ChatGLM等
7.4 智能体应用开发与API调用
百炼智能体支持通过API调用,也支持一键发布到第三方平台,或通过组件集成到业务流程中。在智能体应用的发布渠道页签,单击API调用右侧的查看API,查看API调用方法。将YOUR_API_KEY替换为实际的百炼API Key后方可发起调用。
以下是一个调用百炼大模型API的Python示例:
import requests
import json
url = "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation"
headers = {
"Content-Type": "application/json",
"Authorization": "Bearer YOUR_API_KEY"
}
data = {
"model": "qwen-max",
"input": {
"messages": [
{
"role": "system",
"content": "你是一个智能决策助手"
},
{
"role": "user",
"content": "请分析以下销售数据并给出决策建议:2026年Q2销售额为5200万元,环比增长8.3%,其中华东地区贡献45%,华南地区贡献30%。"
}
]
},
"parameters": {
"result_format": "message",
"temperature": 0.7
}
}
response = requests.post(url, headers=headers, json=data)
print(json.loads(response.text))八、平台对接最佳实践
8.1 网络连通方案
在对接各类数据源时,网络连通是关键前提。推荐使用私网连接:当资源组与数据源在同一VPC内时,使用VPC地址进行连接。公网连接需将相应IP地址添加至数据源白名单。
网络连通方案的选择建议:
- 同VPC内网:优先推荐,延迟最低且无公网流量费用
- 跨VPC对等连接:适用于不同VPC之间的通信
- VPN/专线:适用于本地数据中心与云上环境的连接
- 公网连接:仅在没有内网通路时使用,需配置白名单
8.2 权限管理
使用RAM子账号进行操作时,需确保已完成权限策略授权。建议遵循最小权限原则,为不同角色分配不同的权限策略。
常见的权限策略包括:
- AliyunDataWorksFullAccess:DataWorks全部权限
- AliyunQuickBIFullAccess:Quick BI全部权限
- AliyunPAIFullAccess:PAI全部权限
- AliyunSAFFullAccess:风险识别(含决策引擎)全部权限
- AliyunDashscopeFullAccess:百炼大模型全部权限
8.3 资源规划
DataWorks当前推荐使用Serverless资源组,它涵盖旧版资源组的核心功能,通过一个资源组即可完成数据同步、任务调度运行、调用及管理API服务等操作。对于历史项目仍可使用独享资源组。
资源规划的关键考虑因素:
- 数据同步并发度:根据数据量合理设置并发数
- 调度资源:评估每日任务数量和执行时长
- 存储资源:根据数据增长趋势预留存储空间
- 计算资源:根据业务高峰低谷动态调整
8.4 安全与合规
启用内置的隐私保护引擎,自动识别身份证、银行卡等敏感信息。敏感数据脱敏确保符合GDPR等合规要求。
安全与合规的最佳实践:
- 数据加密:对传输和存储中的敏感数据进行加密
- 访问控制:基于RAM实现细粒度的权限管理
- 审计日志:开启操作审计,追踪所有API调用和配置变更
- 数据脱敏:在分析层面对敏感字段进行脱敏处理
8.5 成本优化
优先利用同地域内网访问免流量费用。合理规划存储类型,将冷数据转为低频或归档存储以降低成本。监控外网流量防止盗刷。
成本优化的具体措施:
- 内网优先:所有云产品优先使用同地域内网地址访问
- 存储分层:热数据用标准存储,冷数据转低频或归档
- 资源弹性:使用Serverless资源组按需付费
- 监控告警:设置外网流量阈值告警,防止异常流量
九、常见问题与解答
问1:DataWorks工作空间创建后地域能否更改?
答:DataWorks工作空间的地域在创建后不可更改。因此在创建工作空间前需要确认好目标地域。
问2:决策引擎的事件和策略有什么区别?
答:事件是业务场景的抽象定义(如注册场景、营销场景),用于定义入参数据结构;策略是具体的运算逻辑,当事件数据请求进入决策引擎时,系统会根据配置的策略进行运算并返回结果。
问3:PAI EAS部署的模型如何获取调用信息?
答:在PAI控制台的EAS页面查看已部署的服务,点击"查看调用信息"即可获取endpoint和token信息。
问4:Quick BI连接MaxCompute需要哪些权限?
答:需要具备MaxCompute项目的CreateInstance、List和表的Desc权限;若需要上传文件,还需要拥有项目的CreateTable、Write权限。
问5:百炼智能体如何通过API调用?
答:在智能体应用的发布渠道页签,单击"API调用"右侧的"查看API"获取调用方法,将YOUR_API_KEY替换为实际的百炼API Key即可发起调用。
问6:DataWorks标准模式与简单模式有何区别?
答:标准模式提供独立的开发与生产环境,是保障数据安全和流程规范的最佳选择;简单模式仅有生产环境,适用于个人测试或快速验证场景。


