输入模块简介 hilens::AudioCapture类 使用音频采集器来读取本地音频文件的数据，相关头文件已集成到“hilens.h”。 #include <hilens.h> 构造及析构函数 ~AudioCapture() virtual hilens::AudioCapture::~AudioCapture()

查看更多 →

错误信息：正则表达式校验失败时，提示的错误信息。 校验错误信息：当“自定义校验”中，JS代码返回值类型为布尔类型时，会取该参数的值为错误提示信息。当“自定义校验”中JS代码返回值类型为对象类型时，直接取返回值中的message值为错误提示信息。 事件：在事件中，显示了组件暴露出来的一些常用事件，供用户实现，来

查看更多 →

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

查看更多 →

创建输入流 CloudTable HBase输入流 DIS输入流 DMS输入流 EdgeHub输入流（EOS） MRS Kafka输入流 开源Kafka输入流 OBS输入流 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）

查看更多 →

Array of integers 输入值需要大于等于最小值，并小于等于最大值。 regex String 输入值需要满足正则表达式 valid_values Array of integers/string/float/boolean 输入值需要符合给定值中的任意一个 equal Integer

查看更多 →

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

查看更多 →

如下接口不建议用户使用，若用户需要使用，请联系华为技术支持获取接口详细使用方法。

查看更多 →

Python模块 您可以使用该配置来运行任意Python模块。 启动配置属性 启动配置示例 父主题： 启动配置

查看更多 →

database_names() print "connect database success! database names is %s" % dbs URL中的认证数据库必须为“admin”，即“authSource=admin”。 SSL方式连接，需要手动生成trustStore文件。 认证数据

查看更多 →

database_names() print "connect database success! database names is %s" % dbs URL中的认证数据库必须为“admin”，即“authSource=admin”。 SSL方式连接，需要手动生成trustStore文件。 认证数据

查看更多 →

安装Python 用户没有sudo权限 输入的路径没有权限 部署应用中断 权限不够 参数含反斜杠“\”（特例） 环境下没有主机 环境不存在 windows主机部署应用失败 使用sudo权限执行报错 部署进程被第三方杀毒软件拦截 Windows主机上检测到版本与安装版本不匹配 路径不合法

查看更多 →

选择当前资源类型为主机集群的环境，作为部署对象。 python版本 python的版本。 python安装路径 python的安装路径。 控制选项 配置是否启用该操作。 当前步骤部署失败后，应用是否继续部署后续的步骤。 配置是否使用sudo权限部署该步骤。 若在部署过程中遇到问题，可参考该步骤的常见问题解决办法。

查看更多 →

全托管式的Kafka消息队列。 DLI 支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。创建DMS Kafka输入流的语法与创建开源Apache Kafka输入流一样，具体请参见开源Kafka输入流。 父主题： 创建输入流

查看更多 →

视频输入模块 视频采集器 读取摄像头视频帧 获取视频的宽度 获取视频的高度 示例-输入

查看更多 →

Key，与访问密钥ID结合使用的密钥。访问密钥获取方式请参见我的凭证。 bucket 是 数据所在的OBS桶名。 object_name 是 数据所在OBS桶中的对象名。如果对象不在OBS根目录下，则需添加文件夹名，例如：test/test.csv。对象文件格式参考“encode”参数。 row_delimiter

查看更多 →

创建输入流 CloudTable HBase输入流 DIS输入流 DMS输入流 MRS Kafka输入流 开源Kafka输入流 OBS输入流 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）

查看更多 →

Key，与访问密钥ID结合使用的密钥。访问密钥获取方式请参见我的凭证。 bucket 是 数据所在的OBS桶名。 object_name 是 数据所在OBS桶中的对象名。如果对象不在OBS根目录下，则需添加文件夹名，例如：test/test.csv。对象文件格式参考“encode”参数。 row_delimiter

查看更多 →

全托管式的Kafka消息队列。 DLI支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。创建DMS Kafka输入流的语法与创建开源Apache Kafka输入流一样，具体请参见开源Kafka输入流。 父主题： 创建输入流

查看更多 →

CS V文件输入 概述 “CSV文件输入”算子，用于导入所有能用文本编辑器打开的文件。 输入与输出 输入：文本文件 输出：多个字段 参数说明 表1 算子参数说明 参数 含义 类型 是否必填 默认值 分隔符 CSV文件的列分隔符，用于分隔每行的数据。 string 是 , 换行符 用

查看更多 →

错误信息：正则表达式校验失败时，提示的错误信息。 校验错误信息：当“自定义校验”中，JS代码返回值类型为布尔类型时，会取该参数的值为错误提示信息。当“自定义校验”中JS代码返回值类型为对象类型时，直接取返回值中的message值为错误提示信息。 事件：在事件中，显示了组件暴露出来的一些常用事件，供用户实现，来

查看更多 →

Content-Type:application/json 响应消息 响应参数 响应中结构如表2所示 表2 execution输入结构 参数 参数类型 描述 inputs JSONObject，请参见inputs 执行结果输入信息。 响应示例 { "inputs": { "data_pvc_name":

查看更多 →