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

查看更多 →

OBS输入流 功能描述 创建source流从 对象存储服务 （OBS）获取数据。 DLI 从OBS上读取用户存储的数据，作为作业的输入数据。适用于大数据分析、原生云应用程序数据、静态网站托管、备份/活跃归档、深度/冷归档等场景。 对象存储服务（Object Storage Service

查看更多 →

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

查看更多 →

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

查看更多 →

虚拟机治理 方案介绍 约束与限制 部署ASM-PROXY 验证服务访问 流量治理 卸载ASM-PROXY

查看更多 →

配置虚拟机 安装virtio驱动 在Windows虚拟机中安装Virtualbox增强功能 安装Cloudbase-Init（可选） 安装一键式重置密码插件（可选） 父主题： 基于VirtualBox使用ISO创建Windows镜像

查看更多 →

创建虚拟机 创建空虚拟机 安装Linux操作系统 父主题： 基于VirtualBox使用ISO创建Linux镜像

查看更多 →

虚拟机环境配置 虚拟机Windows操作系统安装完成后，需要关闭防火墙，并配置远程桌面启动。 操作步骤 单击左下角的图标，选择“ 服务器 管理”，进入“服务器管理”页面。 在左侧导航树中选择“ 本地服务器 ”，在右侧“Windows防火墙”区域，单击其后的状态链接。 在“Windows防

查看更多 →

创建空虚拟机 前提条件 已安装VirtualBox。 操作步骤 打开VirtualBox，单击“新建”，在弹出的“新建虚拟电脑”对话框中输入虚拟机名称，并选择类型和版本，单击“下一步”。 以Ubuntu为例，类型选择：Linux。 请确保选择的版本与待安装的操作系统版一致。 图1

查看更多 →

Jenkins全局工具配置：用于Jekins流水线打包脚本对接git拉取代码并打包。 安装Jenkins插件 在浏览器地址栏输入http://{安装Jekins的Linux虚拟机IP}:8080，登录Jenkins。 选择“系统管理 > 插件管理”。 单击“可选插件”，搜索表1中的插件进行安装。

查看更多 →

如何解决“运维Windows服务器时使用WPS软件输入中文异常”的问题？ 运维Windows服务器时，使用WPS软件输入文字出现重复现象，例如：输入“云 堡垒机 ”会出现“云云云云”。 解决办法 将本地电脑的输入法设置为英文。 将被运维的Windows服务器的输入法设置为中文。 父主题： 运维故障

查看更多 →

执行如下命令切换root用户。 sudo su 输入设置的用户密码。 安装SysAgent，执行如下命令。 将下载的HDPSysAgent_Linux_Server_Release.zip包拷贝至/tmp目录。 mv /存放SysAgent安装包的目录/HDPSysAgent_Linux_Server_Release

查看更多 →

制作Linux空壳镜像 镜像准备 Linux镜像可在现网公共镜像基础上进行修改。 选择Linux公共镜像，将镜像直接下发为虚拟机即可，注意密码设置符合要求的密码。（由于软件python脚本使用python3版本编写，镜像需包含python3版本，若不包含，需手动安装）。 脚本准备

查看更多 →

查询workflow输入 功能介绍 查询特定流程输入。 URI GET /v1/workflows/{workflow_id}/inputs 表1 参数说明 参数 是否必选 参数类型 描述 workflow_id 是 String 需要查询流程的id，即创建workflow的返回值。

查看更多 →

自拓展输入流 用户可通过编写代码实现从想要的云生态或者开源生态获取数据，作为Flink作业的输入数据。 语法格式 1 2 3 4 5 6 7 CREATE SOURCE STREAM stream_id (attr_name attr_type (',' attr_name attr_type)*

查看更多 →

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

查看更多 →

get_workflow_inputs(workflow_id)查询流程输入。

查看更多 →

任务输入/输出参数 task.input（任务输入参数） task.input参数说明 参数 是否必选 类型 说明 type 是 String 视频数据的输入类型： obs：表示从华为云OBS中读取视频数据。 url：表示从指定的URL地址中读取视频数据。 edgecamera：表示从指定的边缘摄像头读取数据。

查看更多 →

配置分析任务输入 点击目标分析任务，如下图1所示。 图1 目标分析任务 点击资产ID的修改图标进行修改，如下图2所示（只有属性引用类型为“引用其他资产属性”的输入参数需要配置资产ID）。 图2 资产ID 父主题： 工作台

查看更多 →

CloudTable HBase输入流 功能描述 创建source流从 表格存储服务 CloudTable的HBase中获取数据，作为作业的输入数据。HBase是一个稳定可靠，性能卓越、可伸缩、面向列的分布式云存储系统，适用于海量数据存储以及分布式计算的场景，用户可以利用HBase搭

查看更多 →

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

查看更多 →