开天集成工作台资源中心

String 按照用户配置的工作流请求头参数配置，如果用户配置的工作流输入存在请求头输入，则应该配置对应的参数并在调用时输入特定的值。 表4 请求Body参数 参数 是否必选 参数类型 描述 body 否 Object 调用流请求体，与工作流起始节点配置相关，按照工作流的配置格式填写即可。 响应参数

查看更多 →

计算收货数量 执行存储过程查询发料行 数据追加到数组变量 如果有data变量有数据，则调用子流程，创建生产发料 无论是否倒扣料，调用子流程创建出入库单据 将子流程的响应结果直接封装到响应体返回 保存 父主题： 创建保存数据业务流

查看更多 →

的数据实时传输到云服务内的问题。 数据接入服务 每小时可从数十万种数据源（如IoT数据采集、日志和定位追踪事件、网站点击流、社交媒体源等）中连续捕获、传送和存储数TB数据。DIS的更多信息，请参见《数据接入服务用户指南》。 语法格式 1 2 3 4 5 6 7 8 9 CREATE SINK

查看更多 →

的数据实时传输到云服务内的问题。数据接入服务每小时可从数十万种数据源（如IoT数据采集、日志和定位追踪事件、网站点击流、社交媒体源等）中连续捕获、传送和存储数TB数据。DIS的更多信息，请参见《数据接入服务用户指南》。 语法格式 1 2 3 4 5 6 7 8 9 CREATE SINK

查看更多 →

待插入数据字段的key，具体形式如："f1,f2,f3"，并且保证与sink中数据列一一对应。 batch_insert_data_num 否 表示一次性批量写入的数据量，值必须为正整数，默认值为10。 示例 将流qualified_cars 的数据输出到文档数据库collectionTest。 1 2

查看更多 →

待插入数据字段的key，具体形式如："f1,f2,f3"，并且保证与sink中数据列一一对应。 batch_insert_data_num 否 表示一次性批量写入的数据量，值必须为正整数，默认值为10。 示例 将流qualified_cars 的数据输出到文档数据库collectionTest。 1 2

查看更多 →

json_config 否 当编码格式为json时，用户可以通过该参数来指定json字段和流定义字段的映射关系，格式为“field1=data_json.field1;field2=data_json.field2”。 obs_dir 是 文件存储目录。格式为{桶名}/{目录名}，

查看更多 →

json_config 否 当编码格式为json时，用户可以通过该参数来指定json字段和流定义字段的映射关系，格式为“field1=data_json.field1;field2=data_json.field2”。 obs_dir 是 文件存储目录。格式为{桶名}/{目录名}，

查看更多 →

响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 data data object 查询流日志返回值数据 表5 data 参数 参数类型 描述 total Integer 查询流日志返回值记录总数 limit Integer 每页显示个数，范围为1-1024

查看更多 →

Array of OperationState objects 函数流节点清单，定义参考SleepState和OperationState 数组长度：1 - 100 constants 是 Object 函数流中的常量 retries 是 Array of Retry objects

查看更多 →

name>"; // 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量ACCESS_KEY_ID和SECRET_ACCESS_KEY。

查看更多 →

illegal_data_table = "illegal_data", batch_insert_data_num = "20", action = "add", krb_auth = "KRB_AUTH_NAME" ); 父主题： 创建输出流

查看更多 →

HBase提供的分布式、可伸缩、全托管的KeyValue数据存储服务，为 DLI 提供了高性能的随机读写能力，适用于海量结构化数据、半结构化数据以及时序数据的存储和查询应用，适用于物联网IOT应用和通用海量KeyValue数据存储与查询等场景。CloudTable的更多信息，请参见《 表格存储服务 用户指南》。 前提条件

查看更多 →

反映了一个对象随时间的变化状态或程度。支持秒级别数据的采集监控，进行永久存储，索引和查询，可用于系统监控和测量、物联网数据、金融数据和科学实验结果数据的收集监控。 表格存储 服务（CloudTable），是基于Apache HBase提供的分布式、可伸缩、全托管的KeyValue数

查看更多 →

反映了一个对象随时间的变化状态或程度。支持秒级别数据的采集监控，进行永久存储，索引和查询，可用于系统监控和测量、物联网数据、金融数据和科学实验结果数据的收集监控。 表格存储服务（CloudTable），是基于Apache HBase提供的分布式、可伸缩、全托管的KeyValue数

查看更多 →

自拓展输出流 用户可通过编写代码实现将DLI处理之后的数据写入指定的云生态或者开源生态。 语法格式 CREATE SINK STREAM stream_id (attr_name attr_type (',' attr_name attr_type)* ) WITH (

查看更多 →

删除工作流 功能介绍 本接口用于标记删除工作流。 请求消息样式 DELETE /v2/workflows/{graph_name} HTTP/1.1 Host: obs.cn-north-4.myhuaweicloud.com Authorization: authorization

查看更多 →

数据点的timestamp，数据类型支持LONG、INT、SHORT和STRING，仅支持指定动态列。 tsdb_values 是 数据点的value，数据类型支持SHORT、INT、LONG、FLOAT、DOUBLE和STRING，支持指定动态列或者常数值。 tsdb_tags 是

查看更多 →

数据点的timestamp，数据类型支持LONG、INT、SHORT和STRING，仅支持指定动态列。 tsdb_values 是 数据点的value，数据类型支持SHORT、INT、LONG、FLOAT、DOUBLE和STRING，支持指定动态列或者常数值。 tsdb_tags 是

查看更多 →

data_type 格式 无。 说明 数据类型，当前只支持原生数据类型。 父主题： 标示符

查看更多 →

EdgeHub输出流（EOS） 功能描述 DLI将边缘作业分析处理过的数据，写入到EdgeHub中，便于后续进行处理。 适用于物联网IOT场景，将实时流计算能力从云端延伸到边缘，在边缘快速实现对流数据实时、快速、准确地分析处理，增加数据处理计算的速度和效率。同时将数据在边缘预处理

查看更多 →