即使用同一个选择的委托或不使用任何委托。如图5所示。 图5 设置委托 函数配置委托，比如函数需要创建DIS触发器，则需要配置具有DIS访问权限的委托。当没有使用任何函数配置委托或者函数配置委托不存在时，不能创建DIS触发器。 函数执行委托配置后用户可以通过函数执行入口方法中的co

查看更多 →

接入DIS数据源 概述 ROMA Connect支持把DIS（ 数据接入服务 ）作为一个数据源，并用于数据集成任务。在使用DIS数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。 操作步骤

查看更多 →

“启动”。 如果启动失败可以联系技术支持工程师。 配置Kafka事件触发函数 返回 函数工作流 控制台，在左侧的导航栏选择“函数 > 函数列表”。 选择待配置的函数，单击进入函数详情页。 在函数详情页，选择函数版本。 在“代码”页签下，单击“测试”，弹出“配置测试事件”对话框。 填写如表1所示测试信息后，单击“保存”。

查看更多 →

该解决方案基于华为云函数工作流 FunctionGraph无服务器架构，将云服务（如：弹性云服务器 E CS 、对象存储服务 OBS、统一身份认证服务 IAM等）产生的事件发送到事件网格 EG中，事件网格对事件进行校验、过滤、路由和转化，然后推送给已经订阅事件的函数。在函数中执行业务处理逻辑，并将关键的事件信息通过消息通知服务

查看更多 →

数据转发至华为云服务 数据转发至DIS 数据转发至RocketMQ 数据转发至GeminiDB Influx 数据转发至Kafka存储 数据转发至FunctionGraph函数工作流 数据转发至MySQL存储 数据转发至OBS长期存储 数据转发至 BCS 可信上链 数据转发至MongoDB存储

查看更多 →

对象存储服务 OBS：是一个基于对象的海量存储服务，为客户提供海量、安全、高可靠、低成本的数据存储能力。 函数工作流 FunctionGraph：是一项基于事件驱动的函数托管计算服务。使用FunctionGraph函数，只需编写业务函数代码并设置运行的条件，无需配置和管理服务器等基

查看更多 →

由到微服务容器中，同时支持微服务的灰度发布。 函数工作流服务开放 API网关可以将无服务器服务（即函数工作流服务）作为后端服务开放给合作伙伴，与传统的服务相比，函数工作流服务具有易开发、易部署、易维护的特点。使用函数工作流服务，快速构建后端业务逻辑处理，将这些业务逻辑函数通过AP

查看更多 →

DIS数据源 算子简介 名称： DIS数据源，IoT数据分析服务仅在华为云部署形态支持DIS数据源。 功能说明： 使用DIS云服务作为pipeline的数据源，从DIS中获取数据。 约束： 下游不允许对接数据源，目前有：IoT设备接入数据源、DIS数据源，及产品过滤算子。 算子配置

查看更多 →

数据转发至DIS 场景说明 将数据流转到DIS云服务，可让您轻松收集、处理和分发实时流数据，以便您对新信息快速做出响应。DIS对接多种第三方数据采集工具，提供丰富的云服务Connector及Agent/SDK。也可以通过转储任务进一步将数据转发到其他云服务进行数据存储、分析，便于客户灵活使用。

查看更多 →

，建议您不使用） 系统角色 Tenant Guest FunctionGraph Invoker 函数工作流（FunctionGraph）调用者，具有查询函数、工作流、触发器以及调用函数的权限 系统角色 无 FunctionGraph FullAccess 函数工作流服务所有权限

查看更多 →

用来分发数据流到下一个步骤的函数 Pod 中。 操作步骤 创建一个图片压缩的函数，其中代码在处理返回数据通过 ctx.Write() 函数将结果以流式数据的形式返回： 目前只支持go函数！ FunctionGraph 通过 ctx.Write() 函数提供了流式返回的能力，对开发者来说，只需要将最终

查看更多 →

S桶中。 使用函数工作流FunctionGraph，用于实现调用情感分析服务业务逻辑，当收到OBS上传文段通知后，自动调用NLP情感分析服务进行语义识别，并将结果存放在OBS桶内。 使用NLP情感分析，提供用户评论情感分析。用户只需将文本上传至OBS桶，即可自动识别该文本情感（正负），以及标签置信度。

查看更多 →

使用distcp命令跨集群复制HDFS数据 操作场景 distcp是一种在集群间或集群内部拷贝大量数据的工具。它利用MapReduce任务实现大量数据的分布式拷贝。 前提条件 已安装Yarn客户端或者包括Yarn的客户端。例如安装目录为“/opt/client”。 各组件业务用户

查看更多 →

该解决方案帮助您无服务器架构实现弹性云服务器 ECS日志的采集、分析、告警以及存档，基于云日志服务 LTS实时采集弹性云服务器 ECS的日志数据，通过函数工作流 FunctionGraph的LTS触发器自动获取日志数据，并实现对日志中告警信息的分析，通过消息通知服务 SMN将告警信息推送给用户，并存储到 对象存储服务

查看更多 →

使用DIS Flink Connector上传与下载数据 DIS Flink Connector概述 准备DIS Flink Connector的相关环境 自定义Flink Streaming作业 父主题： 使用DIS

查看更多 →

使用distcp命令跨集群复制HDFS数据 操作场景 distcp是一种在集群间或集群内部复制大量数据的工具。它利用MapReduce任务实现大量数据的分布式复制。 前提条件 已安装Yarn客户端或者包括Yarn的客户端。例如安装目录为“/opt/client”。 各组件业务用户

查看更多 →

具体操作请参见《数据接入服务用户指南》中的安装DIS Agent和配置DIS Agent配置DIS Agent。 启动DIS Agent，将采集的本地数据上传到DIS队列中。 具体操作请参见《数据接入服务用户指南》中的启动DIS Agent。 例如：将如下数据通过DIS Agent上传到DIS队列中。

查看更多 →

打开Notebook 实现数据预热和数据异步留存功能 实现数据预热功能。每次训练前需要读取OBS中的数据时，可以使用该功能将要用的数据提前上传到SFS Turbo中。 打开函数工作流functiongraph，打开带有preload-data前缀的函数。 图29 打开对应函数 配置空白测试事件，运行函数即可触发预热功能。

查看更多 →

数据处理 在数据服务首页左侧导航，选择“首页>我的数据集”。 在“我的数据集”页签单击新增的数据集。 单击“应用数据集 > 数据处理”。 进入“新增作业”界面，如图1所示。 参数说明如下所示： 作业名称：自定义输入。 开发环境：选择通用编辑器。 作业位置：存储作业脚本的数据湖OB

查看更多 →

数据处理 数据处理支持什么类型脚本？ 运行环境如何安装Python包？ 数据处理可以处理哪些数据源中的数据？ 用户注销后，是否会清理数据服务对应的个人数据以及资源，是否还会计费？ 父主题： 常见问题

查看更多 →

数据处理 Python API接口 管理新增作业 创建开发环境 父主题： 管理基础工具

查看更多 →