阿里云助力您在中国加快取得成功
一站式安全合规咨询服务
MLPS 2.0 一站式合规解决方案
依托我们的网络进军中国市场
提升面向互联网应用的性能和安全性
保障您的中国业务安全无忧
通过强大的数据安全框架保护您的数据资产
申请 ICP 备案的流程解读和咨询服务
面向大数据建设、管理及应用的全域解决方案
企业内大数据建设、管理和应用的一站式解决方案
将您的采购和销售置于同一企业级全渠道数字平台上
全渠道内置 AI 驱动、拟人化、多语言对话的聊天机器人
快速搭建在线教育平台
提供域名注册、分析和保护服务
云原生 Kubernetes 容器化应用运行环境
以 Kubernetes 为使用界面的容器服务产品,提供符合容器规范的算力资源
安全的镜像托管服务,支持全生命周期管理
多集群环境下微服务应用流量统一管理
提供任意基础设施上容器集群的统一管控,助您轻松管控分布式云场景
高弹性、高可靠的企业级无服务器 Kubernetes 容器产品
敏捷安全的 Serverless 容器运行服务
为虚拟机和容器提供高可靠性、高性能、低时延的块存储服务
一款海量、安全、低成本、高可靠的云存储服务
可靠、弹性、高性能、多共享的文件存储服务
全托管、可扩展的并行文件系统服务。
全托管的 NoSQL 结构化数据实时存储服务
可抵扣多种存储产品的容量包,兼具灵活性和长期成本优化
让您的应用跨不同可用区资源自动分配访问量
随时绑定和解绑 VPC ECS
云网络公网、跨域流量统一计费
高性价比,可抵扣按流量计费的流量费用
创建云上隔离的网络,在专有环境中运行资源
在 VPC 环境下构建公网流量的出入口
具备网络状态可视化、故障智能诊断能力的自助式网络运维服务。
安全便捷的云上服务专属连接
基于阿里云专有网络的私有 DNS 解析服务
保障在线业务不受大流量 DDoS 攻击影响
系统运维和安全审计管控平台
业务上云的第一个网络安全基础设施
集零信任内网访问、办公数据保护、终端管理等多功能于一体的办公安全管控平台
提供7X24小时安全运维平台
防御常见 Web 攻击,缓解 HTTP 泛洪攻击
实现全站 HTTPS,呈现可信的 WEB 访问
为云上应用提供符合行业标准和密码算法等级的数据加解密、签名验签和数据认证能力
一款发现、分类和保护敏感数据的安全服务
创建、控制和管理您的加密密钥
快速提高应用高可用能力服务
围绕应用和微服务的 PaaS 平台
兼容主流开源微服务生态的一站式平台
多集群环境下微服务应用流量统一管理
企业级全托管实时数据流平台
全托管,开箱即用的Apache Kafka全托管服务
提供物联网移动端和云交互的消息队列
开箱即用的全托管 RabbitMQ 服务
提供基于消息的可靠异步通信机制
应用之间的消息队列和通知
无服务器事件总线服务
Super MySQL 和 PostgreSQL,高度兼容 Oracle 语法
全托管 MySQL、PostgreSQL、SQL Server、MariaDB
兼容 Redis® 的缓存和KV数据库
兼容Apache Cassandra、Apache HBase、Elasticsearch、OpenTSDB 等多种开源接口
文档型数据库,支持副本集和分片架构
100%兼容 Apache HBase 并深度扩展,稳定、易用、低成本的NoSQL数据库。
低成本、高可用、可弹性伸缩的在线时序数据库服务
专为搜索和分析而设计,成本效益达到开源的两倍,采用最新的企业级AI搜索和AI助手功能。
一款兼容PostgreSQL协议的实时交互式分析产品
一种快速、完全托管的 TB/PB 级数据仓库
基于 Flink 为大数据行业提供解决方案
基于Qwen和其他热门模型的一站式生成式AI平台,可构建了解您业务的智能应用程
一站式机器学习平台,满足数据挖掘分析需求
高性能向量检索服务,提供低代码API和高成本效益
帮助您的应用快速构建高质量的个性化推荐服务能力
提供定制化的高品质机器翻译服务
全面的AI计算平台,满足大模型训练等高性能AI计算的算力和性能需求
具备智能会话能力的会话机器人
基于机器学习的智能图像搜索产品
基于阿里云深度学习技术,为用户提供图像分割、视频分割、文字识别等离线SDK能力,支持Android、iOS不同的适用终端。
语音识别、语音合成服务以及自学习平台
一站式智能搜索业务开发平台
助力金融企业快速搭建超低时延、高质量、稳定的行情数据服务
帮助企业快速测算和分析企业的碳排放和产品碳足迹
企业工作流程自动化,全面提高效率
金融级云原生分布式架构的一站式高可用应用研发、运维平台
eKYC 数字远程在线解决方案
可智能检测、大数据驱动的综合性反洗钱 (AML) 解决方案
阿里云APM类监控产品
实时云监控服务,确保应用及服务器平稳运行
为系统运维人员管理云基础架构提供全方位服务的云上自动化运维平台
面向您的云资源的风险检测服务
提升分布式环境下的诊断效率
日志类数据一站式服务,无需开发就能部署
ECS 预留实例
让弹性计算产品的成本和灵活性达到最佳平衡的付费方式。云原生 AI 套件
加速AI平台构建,提高资源效率和交付速度FinOps
实时分析您的云消耗并实现节约SecOps
实施细粒度安全控制DevOps
快速、安全地最大限度提高您的DevOps优势自带IP上云
自带公网 IP 地址上云全球网络互联
端到端的软件定义网络解决方案,可推动跨国企业的业务发展全球应用加速
提升面向互联网应用的性能和安全性全球互联网接入
将IDC网关迁移到云端云原生 AI 套件
加速AI平台构建,提高资源效率和交付速度FinOps
实时分析您的云消耗并实现节约SecOps
实施细粒度安全控制DevOps
快速、安全地最大限度提高您的DevOps优势金融科技云数据库解决方案
利用专为金融科技而设的云原生数据库解决方案游戏行业云数据库解决方案
提供多种成熟架构,解决所有数据问题Oracle 数据库迁移
将 Oracle 数据库顺利迁移到云原生数据库数据库迁移
加速迁移您的数据到阿里云阿里云上的数据湖
实时存储、管理和分析各种规模和类型的数据数码信贷
利用大数据和 AI 降低信贷和黑灰产风险面向企业数据技术的大数据咨询服务
帮助企业实现数据现代化并规划其数字化未来人工智能对话服务
全渠道内置 AI 驱动、拟人化、多语言对话的聊天机器人EasyDispatch 现场服务管理
为现场服务调度提供实时AI决策支持在线教育
快速搭建在线教育平台窄带高清 (HD) 转码
带宽成本降低高达 30%广电级大型赛事直播
为全球观众实时直播大型赛事,视频播放流畅不卡顿直播电商
快速轻松地搭建一站式直播购物平台用于供应链规划的Alibaba Dchain
构建和管理敏捷、智能且经济高效的供应链云胸牌
针对赛事运营的创新型凭证数字服务数字门店中的云 POS 解决方案
将所有操作整合到一个云 POS 系统中元宇宙
元宇宙是下一代互联网人工智能 (AI) 加速
利用阿里云 GPU 技术,为 AI 驱动型业务以及 AI 模型训练和推理加速DevOps
快速、安全地最大限度提高您的DevOps优势数据迁移解决方案
加速迁移您的数据到阿里云企业 IT 治理
在阿里云上构建高效可控的云环境基于日志管理的AIOps
登录到带有智能化日志管理解决方案的 AIOps 环境备份与存档
数据备份、数据存档和灾难恢复用阿里云金融服务加快创新
在云端开展业务,提升客户满意度
为全球资本市场提供安全、准确和数字化的客户体验
利用专为金融科技而设的云原生数据库解决方案
利用大数据和 AI 降低信贷和黑灰产风险
建立快速、安全的全球外汇交易平台
新零售时代下,实现传统零售业转型
利用云服务处理流量波动问题,扩展业务运营、降低成本
快速轻松地搭建一站式直播购物平台
面向大数据建设、管理及应用的全域解决方案
全渠道内置 AI 驱动、拟人化、多语言对话的聊天机器人
以数字化媒体旅程为当今的媒体市场准备就绪您的内容
带宽成本降低高达 30%
快速轻松地搭建一站式直播购物平台
为全球观众实时直播大型赛事,视频播放流畅不卡顿
使用阿里云弹性高性能计算 E-HPC 将本地渲染农场连接到云端
构建发现服务,帮助客户找到最合适的内容
保护您的媒体存档安全
通过统一的数据驱动平台提供一致的全生命周期客户服务
在钉钉上打造一个多功能的电信和数字生活平台
在线存储、共享和管理照片与文件
提供全渠道的无缝客户体验
面向中小型企业,为独立软件供应商提供可靠的IT服务
打造最快途径,助力您的新云业务扬帆起航
先进的SD-WAN平台,可实现WAN连接、实时优化并降低WAN成本
通过自动化和流程标准化实现快速事件响应
针对关键网络安全威胁提供集中可见性并进行智能安全分析
提供大容量、可靠且高度安全的企业文件传输
用智能技术数字化体育赛事
基于人工智能的低成本体育广播服务
专业的广播转码及信号分配管理服务
基于云的音视频内容引入、编辑和分发服务
在虚拟场馆中模拟关键运营任务
针对赛事运营的创新型凭证数字服务
智能和交互式赛事指南
轻松管理云端背包单元的绑定直播流
通过数据加强您的营销工作
元宇宙是下一代互联网
利用生成式 AI 加速创新,创造新的业务佳绩
阿里云高性能开源大模型
借助AI轻松解锁和提炼文档中的知识
通过AI驱动的语音转文本服务获取洞察
探索阿里云人工智能和数据智能的所有功能、新优惠和最新产品
该体验中心提供广泛的用例和产品帮助文档,助您开始使用阿里云 AI 产品和浏览您的业务数据。
利用阿里云 GPU 技术,为 AI 驱动型业务以及 AI 模型训练和推理加速
元宇宙是下一代互联网
构建发现服务,帮助客户找到最合适的内容
全渠道内置 AI 驱动、拟人化、多语言对话的聊天机器人
加速迁移您的数据到阿里云
在阿里云上建立一个安全且易扩容的环境,助力高效率且高成本效益的上云旅程
迁移到完全托管的云数据库
将 Oracle 数据库顺利迁移到云原生数据库
自带公网 IP 地址上云
利用阿里云强大的安全工具集,保障业务安全、应用程序安全、数据安全、基础设施安全和帐户安全
保护、备份和还原您的云端数据资产
MLPS 2.0 一站式合规解决方案
快速高效地将您的业务扩展到中国,同时遵守适用的当地法规
实现对 CloudOps、DevOps、SecOps、AIOps 和 FinOps 的高效、安全和透明的管理
构建您的原生云环境并高效管理集群
快速、安全地最大限度提高您的DevOps优势
实施细粒度安全控制
提供运维效率和总体系统安全性
实时分析您的云消耗并实现节约
实时存储、管理和分析各种规模和类型的数据
登录到带有智能化日志管理解决方案的 AIOps 环境
帮助企业实现数据现代化并规划其数字化未来
帮助零售商快速规划数字化之旅
将全球知名的 CRM 平台引入中国
在线存储、共享和管理照片与文件
构建、部署和管理高可用、高可靠、高弹性的应用程序
快速、安全地最大限度提高您的DevOps优势
将您的采购和销售置于同一企业级全渠道数字平台上
企业内大数据建设、管理和应用的一站式解决方案
帮助企业简化 IT 架构、实现商业价值、加速数字化转型的步伐
快速高效地将您的业务扩展到中国,同时遵守适用的当地法规
快速搜集、处理、分析联网设备产生的数据
0.0.201
补数据可通过补历史或未来一段时间的数据,将写入数据至对应时间分区。代码中的调度参数,将根据补数据选择的业务时间自动替换为具体值,并结合业务代码将对应时间数据写入指定分区。具体写入的分区与执行的代码逻辑,与任务定义的代码有关。本文为您介绍新版补数据如何执行补数据操作并管理补数据实例。
实例清理原则
不支持手动删除补数据实例,实例过期后(30天左右)平台将自动删除。如果任务不需要再运行,可选择冻结实例。
公共调度资源组实例保留一个月(30天),日志保留一周(7天)。
独享调度资源组与Serverless资源组的任务实例、日志均保留一个月(30天)。
运行完成的实例,当日志大于3 MB时,平台会每天定时清理。
权限限制
对于补数据中选择的根任务或其下游任务,若您没有任务所在工作空间的操作权限,则无法对该任务执行补数据。如果工作空间的任务为本次补数据的中间任务(即该任务的上下游依赖在此次补数据范围内),为保障下游任务运行,该任务将空跑(不会真实执行,任务启动运行后立即返回成功状态),可能导致该任务的下游任务数据产出异常,请谨慎操作。
实例运行相关
当补一个区间的数据时,若启动补数据的第一天存在一个运行失败的实例,则当天的补数据实例均会被置为失败状态,第二天的实例也不会启动运行。仅当第一天的全部实例均运行成功,第二天的实例才会启动运行。
小时或分钟任务补某一天数据时,当天所有实例是否并发执行与任务是否设置自依赖有关。
如果周期实例和补数据实例均启动运行,为保证周期实例正常运行,您需要终止补数据实例的运行。
支持将无需补数据的任务添加至黑名单。若黑名单中的任务为本次补数据的中间任务(即该任务的上下游依赖在此次补数据范围内),为保障下游任务运行,该任务将空跑(不会真实执行,任务启动运行后立即返回成功状态),但可能导致该任务的下游任务数据产出异常。
调度资源相关
补数据实例过多或并行数过高可能导致周期调度的资源紧张,请根据需求合理配置。
为避免补数据实例占用过多的资源而影响周期实例运行,平台对补数据实例制定以下规则:
如果补数据选择业务日期为昨天(T-1),即补当天数据时,补数据任务优先级由任务所在基线优先级决定。
如果补数据选择业务日期为历史业务日期(T-2)时,补数据任务将按照以下规则对任务进行降级处理:
7级、8级任务优先级降为3级。
5级、3级任务优先级降为2级。
1级任务优先级保持不变。
进入运维中心页面。
登录DataWorks控制台,切换至目标地域后,单击左侧导航栏的数据开发与运维 > 运维中心,在下拉框中选择对应工作空间后单击进入运维中心。
在左侧导航栏单击运维助手 > 补数据,进入补数据页面。
如需对某个周期任务补数据,也可在周期任务运维 > 周期任务界面,单击对应任务后的补数据。
在补数据页面单击新建补数据任务,根据业务需求配置补数据任务。
配置基础信息。
平台自动生成默认格式的补数据名称,您可按需修改。
选择要补数据的任务。
您可通过手动选择、按链路、按工作空间、指定任务及所有下游等方式,对您有权限操作的任务发起补数据,并基于该任务选择需要补数据的其他任务,不同方式的配置参数存在差异。
选择一个或多个任务作为根任务,再选择根任务的下游任务作为本次补数据的任务范围。该方式兼容原“当前节点”、“当前节点及下游节点”以及“高级模式”补数据方案。
兼容原当前节点、当前节点及下游节点、高级模式等补数据方案。
最大支持同时补的根任务数上限为500,总任务数(即根任务及其下游任务)上限为2000。
详细参数说明如下。
参数 | 描述 |
方式选择 | 选择手动选择。 |
搜索根任务 | 通过名称或ID搜索、添加根任务。您也可单击批量添加,通过资源组、调度周期、工作空间等条件搜索,批量添加多个根任务。 说明 仅支持选择您已加入工作空间(即您为工作空间成员)的任务。 |
已选补数据列表 | 待执行补数据的任务。列表展示已添加的根任务,您可基于根任务选择要执行补数据的下游任务。 说明
|
任务黑名单 | 若某任务无需补数据,可将其添加至黑名单。黑名单中的任务将不参与本次补数据。 说明
|
选择一个起始任务,以及一个或多个结束任务,通过自动分析,将根任务与结束任务间的所有任务作为本次补数据的任务范围(包括起始任务和结束任务)。
详细参数说明如下。
参数 | 描述 |
方式选择 | 选择按链路。 |
搜索任务 | 通过名称或ID搜索,添加一个起始任务,以及一个或多个结束任务,平台将根据起始及结束任务分析中间任务(即中间任务为起始任务的直接或间接下游任务,为结束任务的直接或间接上游任务)。 |
中间任务列表 | 平台根据起始任务及结束任务自动分析到的中间任务列表。 说明 列表仅展示2000个任务,超过2000的任务不会被展示,但会正常执行。 |
任务黑名单 | 若某任务无需补数据,可将其添加至黑名单。黑名单中的任务将不参与本次补数据。 说明 若黑名单中的任务为本次补数据的中间任务(即该任务的上下游依赖在此次补数据范围内),为保障下游任务运行,该任务将空跑(不会真实执行,任务启动运行后立即返回成功状态),但可能导致该任务的下游任务数据产出异常。 |
选择一个任务作为根任务,并按照下游节点所在工作空间确定本次补数据的任务范围。该方式兼容原“海量节点模式”补数据方案。
兼容原海量节点模式补数据方案。
不支持配置任务黑名单。
详细参数说明如下。
参数 | 描述 |
方式选择 | 选择按工作空间。 |
搜索根任务 | 通过名称或ID搜索、添加根任务。平台将对根任务下游任务所在工作空间的任务进行补数据。 说明 仅支持选择您已加入工作空间(即您为工作空间成员)的任务。 |
包含根节点 | 定义此次补数据是否包含根任务。 |
补数据工作空间 | 基于根任务下游任务所在的工作空间,选择需要对哪些工作空间中的节点进行补数据。 说明
|
任务白名单 | 除选中的工作空间包含的节点外,仍需要进行补数据的节点。 |
任务黑名单 | 选中的工作空间中不需要进行补数据的节点。 |
选择一个根任务后,平台会自动分析,将该任务及所有下游任务作为本次补数据的任务范围。
仅在补数据任务运行时,才能看到触发运行的任务,请谨慎使用。
详细参数说明如下。
参数 | 描述 |
方式选择 | 选择指定任务及所有下游。 |
搜索根任务 | 通过名称或ID搜索、添加根任务。平台将对根任务及其所有下游任务进行补数据。 说明
|
任务黑名单 | 若某任务无需补数据,可将其添加至黑名单。黑名单中的任务将不参与本次补数据。 说明 若黑名单中的任务为本次补数据的中间任务(即该任务的上下游依赖在此次补数据范围内),为保障下游任务运行,该任务将空跑(不会真实执行,任务启动运行后立即返回成功状态),但可能导致该任务的下游任务数据产出异常。 |
配置补数据运行策略。
根据业务需要配置补数据任务的运行时间、是否并行、是否触发告警、所使用的资源组等信息。
参数说明如下。
参数 | 描述 |
参数 | 描述 |
业务日期 | 指定所选任务需要进行补数据的业务日期,精确到天。
说明
|
指定周期 | 指定所选任务需要运行的周期。任务的定时时间在该时间段内,任务才会生成实例并执行。您可通过本功能指定小时、分钟调度任务只运行指定周期的实例(即只补指定周期内的数据)。默认为 说明
|
并行 | 若对多个业务日期执行补数据时,可指定若干个分组并发执行本次补数据任务。取值如下:
并行数取值范围为
|
补数据告警 | 设置此次补数据操作是否会触发告警。
|
触发条件 | 设置告警触发条件:
说明 仅当补数据告警选择是时,需配置该参数。 |
告警方式 | 选择通过短信与邮件、短信、邮件等方式接收告警,告警接收人为补数据的发起人。 说明
|
顺序 | 选择按照业务日期正序或业务日期倒序进行补数据。 |
调度资源组 | 指定运行补数据实例使用的资源组。
说明 请注意配置资源组网络连通,否则任务可能运行失败。若指定的资源组未绑定相关工作空间,则仍将使用原有周期任务的资源组。 |
运行时间段 | 指定本次生成的补数据任务在什么时间执行。
|
配置补数据任务校验策略。
用于配置补数据校验失败时是否终止任务执行。平台将对本次补数据任务的基本情况和潜在风险项进行检测,具体如下:
单击提交,补数据任务创建完成。
补数据任务到达配置的运行时间,且不存在异常情况时,补数据任务将自动触发运行。
若满足如下条件,补数据任务将无法运行:
补数据任务开启校验,校验失败将阻塞任务运行。详情请参见新建补数据任务:步骤4。
补数据操作开启了扩展程序检查,检查未通过将阻塞任务运行。详情请参见扩展程序概述。
在左侧导航栏单击运维助手 > 补数据,进入补数据页面。
在补数据页面右侧,单击展开搜索,可通过补数据名称、运行状态、节点类型等条件筛选需要查询的实例,也可快速批量终止正在运行的补数据任务。
在该区域,您可查看补数据实例的相关信息,主要包括:
任务名称:展示补数据实例的名称。单击实例名称前的图标,即可显示该实例的运行日期、运行状态,以及实例包含的节点及运行详情。
检查状态:当前补数据实例的检查状态。
运行状态:包括运行成功、运行失败、等待资源、等待触发等多种状态。您可根据异常状态排查处理相关问题。
节点数:补数据实例包含的节点数量。
业务日期:运行补数据实例的日期。
查看分析结果:可查看任务预计的生成实例、运行日期及风险校验结果,及时处理阻塞任务。
操作:可对补数据实例进行批量终止、批量重跑、复用等操作。
操作名 | 说明 |
操作名 | 说明 |
批量终止 | 可选择批量终止补数据实例中运行中状态的实例,执行此操作后,对应实例将被置为运行失败状态。 说明 不支持终止运行未运行、运行成功、运行失败状态的实例 |
批量重跑 | 批量重新运行补数据实例。 说明
|
复用 | 可选择复用某次补数据操作的节点集,方便您快速选定需要进行补数据的节点。 |
在该区域,可查看补数据实例所包含节点的相关信息,主要包括:
名称:单击节点名称,即可进入节点详情页查看更多节点信息。
定时时间:节点任务设置的定时运行时间。
开始运行时间:节点任务运行的起始时间。
结束时间:节点任务运行的结束时间。
运行时长:节点任务运行的时长。
操作:可对补数据节点任务进行查看DAG图、终止运行、重跑等操作管理。
操作名 | 说明 |
操作名 | 说明 | |
DAG图 | 查看节点的DAG图,分析节点的上下游任务。详情请参见DAG图功能介绍。 | |
终止运行 | 可终止运行运行中状态的节点,执行此操作后,该节点将被置为运行失败状态。 说明
| |
重跑 | 重新运行目标节点任务。 说明 仅支持重跑状态为运行成功和运行失败的节点。 | |
更多 | 重跑下游 | 重新运行目标节点任务的下游节点。 |
置成功 | 将该节点任务的状态置为成功。 | |
暂停(冻结) | 将当前节点置为暂停(冻结)状态,并停止调度。 说明 等待资源、等待时间、运行中(节点代码运行中、数据质量检验中)状态不支持冻结操作。 | |
恢复(解冻) | 将暂停(冻结)的节点恢复调度。 | |
查看血缘 | 查看节点的血缘关系图。 |
对勾选的任务节点,单击终止运行或重跑,即可批量终止运行或重新运行所选的节点任务。
状态类型 | 状态标识 |
状态类型 | 状态标识 |
运行成功状态 | |
未运行状态 | |
运行失败状态 | |
正在运行状态 | |
等待状态 | |
冻结状态 |