开天集成工作台资源中心

手动触发流 手动触发流连接器包含“手动触发器触发事件”一个触发事件。 连接参数 手动触发流连接器无需认证，无连接参数。 手动触发器 “手动触发器触发事件”表示指定流为手动触发流，需要用户单击“运行”按钮运行流，如图1所示，流执行结束后即终止，可以理解为单击一次运行一次。 图1 运行手动触发流

查看更多 →

OBS输出流 功能描述 创建sink流将 DLI 数据输出到 对象存储服务 （OBS）。DLI可以将作业分析结果输出到OBS上。适用于大数据分析、原生云应用程序数据、静态网站托管、备份/活跃归档、深度/冷归档等场景。 对象存储服务（Object Storage Service，简称OBS

查看更多 →

OBS输出流 功能描述 创建sink流将DLI数据输出到对象存储服务（OBS）。DLI可以将作业分析结果输出到OBS上。适用于大数据分析、原生云应用程序数据、静态网站托管、备份/活跃归档、深度/冷归档等场景。 对象存储服务（Object Storage Service，简称OBS

查看更多 →

一个，同时配置时，“topic_urn”优先级更高。 message_subject 是 发往SMN服务的消息标题，用户自定义。 message_column 是 输出流的字段名，其内容作为消息的内容，用户自定义。目前只支持默认的文本消息。 注意事项 无。 示例 将流over_s

查看更多 →

示例六：时间等待节点使用参考 通过函数流的“时间等待”组件实现对函数的延迟调用，函数流设计实现如下： 时间等待默认为60s，如下： 执行如下： 示例七：子流程使用参考 函数工作流服务可以把一些“函数流”作为“子流程”组合成一个新的函数流，这样可以抽取出一些函数流作为公共流进行使用，减少函数编排的重复开发工作流。

查看更多 →

流类型等。 图4 配置 视频流组件中，配置项的配置高于数据配置。 视频流地址：视频流的URL地址。 视频流类型：视频流的协议类型，目前平台内支持的视频流类型为HTTP-FLV、HLS。当视频流类型选择“HTTP-FLV”时，可以设置是否静音播放。 数据 在数据中，设置视频流组件的数据来源，更多介绍请参见数据接入。

查看更多 →

/database' table_name 是 要插入数据的数据库表名。 db_columns 否 支持配置输出流属性和数据库表属性的对应关系，需严格按照输出流的属性顺序配置。 示例： create sink stream a3(student_name string, student_age

查看更多 →

DIS输出流 功能描述 DLI将Flink作业的输出数据写入 数据接入服务 （DIS）中。适用于将数据过滤后导入DIS通道，进行后续处理的场景。 数据接入服务（Data Ingestion Service，简称DIS）为处理或分析流数据的自定义应用程序构建数据流管道，主要解决云服务外

查看更多 →

rejected_concurrent HTTP流控开启生效，关闭后不清零，开启流控期间拒绝的并发连接数。 rejected_new HTTP流控开启生效，关闭后不清零，开启流控期间拒绝的新建连接数。 rejected_deny HTTP流控开启生效，关闭后不清零，配置黑名单拒绝的请求数。 memory_allow

查看更多 →

业务流图 图1 人员管理业务流图 若为私有云或本地部署场景下，添加人员信息时，直接设置用户账号和密码，保存后，人员即为开户状态，详细参考如何注册人员信息？。 父主题： 人员管理

查看更多 →

创建函数流 功能介绍 创建函数流 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/fgs/workflows 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 最小长度：1

查看更多 →

DDS输出流 功能描述 DLI将作业的输出数据输出到文档数据库服务（DDS）中。 文档数据库服务（Document Database Service，简称DDS）完全兼容MongoDB协议，提供安全、高可用、高可靠、弹性伸缩和易用的数据库服务，同时提供一键部署、弹性扩容、容灾、备份、恢复、监控和告警等功能。

查看更多 →

DDS输出流 功能描述 DLI将作业的输出数据输出到文档数据库服务（DDS）中。 文档数据库服务（Document Database Service，简称DDS）完全兼容MongoDB协议，提供安全、高可用、高可靠、弹性伸缩和易用的数据库服务，同时提供一键部署、弹性扩容、容灾、备份、恢复、监控和告警等功能。

查看更多 →

多流Join场景支持配置表级别的TTL时间 本章节适用于 MRS 3.3.0及以后版本。 在Flink双流Join场景下，如果Join的左表和右表其中一个表数据变化快，需要较短时间的过期时间，而另一个表数据变化较慢，需要较长时间的过期时间。目前Flink只有表级别的TTL（Time

查看更多 →

保存成功后，事件流模板构建成功。 图2 模板可见范围 相关操作 在“事件流”页签内，单击列表“操作”列的对应操作，还可编辑、删除事件流。 表3 相关操作 操作 说明 编辑事件流 单击“操作”列“编辑”，或直接单击事件流名称，编辑已创建的事件流信息。 删除事件流 仅支持删除状态为

查看更多 →

发布成功后，表示构建的事件流模板已可以正常使用。 相关操作 在“事件流”页签内，单击列表“操作”列的对应操作，还可编辑、删除事件流。 表3 相关操作 操作 说明 编辑事件流 单击“操作”列“编辑”，或直接单击事件流名称，编辑已创建的事件流信息。 删除事件流 仅支持删除状态为“编辑中”的事件流。单击“

查看更多 →

接受的SQL执行时间进行配置。 socketTimeoutInConnecting 作用：控制建连阶段套接字操作超时值，在建连阶段，如果从网络中读取数据流超过此阈值，则尝试查找下一个节点建连。 建议：该参数仅影响建连阶段的socket超时时间，如果未配置，默认为5s。 autosave

查看更多 →

接受的SQL执行时间进行配置。 socketTimeoutInConnecting 作用：控制建连阶段套接字操作超时值，在建连阶段，如果从网络中读取数据流超过此阈值，则尝试查找下一个节点建连。 建议：该参数仅影响建连阶段的socket超时时间，如果未配置，默认为5s。 autosave

查看更多 →

MRS Kafka输出流 功能描述 DLI将Flink作业的输出数据输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。MRS基于Apache

查看更多 →

共享流模板复制到我的流模板 登录客户的华为云账号，进入 集成工作台 ，选择流编排-我的流模板-共享流模板，选择"SparkPackERP标准单据同步至企业微信_23-11-0"模板，点击复制，复制到我的流模板 复制成功 进入我的流模板，查看刚才复制的流模板 重复步骤1-2，将其它2个共享流模板复制到我的流模板。

查看更多 →

Pro>视觉套件”控制台选择“我的工作流>第二相面积含量测定工作流”新建应用，详细操作请见新建应用。您可以构建第二相面积含量测定模型，能快速准确反馈测定结果。 图1 第二相面积含量测定工作流流程 表1 第二相面积含量测定工作流说明 流程 说明 详细指导 准备数据 在使用第二相面积含量测定工作流开发应用之前

查看更多 →