查询推流域名推流网络带宽监控数据
调用DescribeLiveDomainPushBpsData获取推流域名的推流网络带宽监控数据。使用说明 获取的带宽数据单位为bit/s。支持批量域名查询，多个域名用英文逗号（,）分隔。不指定StartTime和EndTime时，默认读取过去24小时的数据，同时支持按指定的...
API概览
GetContactFlow 获取指定联系流 获取指定联系流。StartEditContactFlow 创建联系流草稿 发起编辑联系流，生成联系流草稿。CommitContactFlow 提交联系流 PublishContactFlow 发布联系流 发布联系流。DiscardEditingContactFlow 撤销联系流...
基于Indexing Service实现数据流管理
在 Stream 页签中，查看获取到的实时数据流。获取实时数据指标。单击左上角。在左侧导航栏，选择 Kibana>Discover。在 Discover 页面，选择对应索引，获取该索引的实时数据指标。更多Kibana日志分析功能请参见 Kibana Guide。常见问题 Q：...
基础设施安全
网络ACL与安全组 与交换机绑定的网络ACL规则控制流入和流出交换机的数据流，与ECS实例相关的安全组规则控制流入和流出ECS实例的数据流。网络ACL和安全组的基本差异如下表所示。对比项 网络ACL 安全组 功能 通过自定义设置网络ACL规则，并将...
网络ACL概述
网络ACL与安全组 与交换机绑定的网络ACL规则控制流入和流出交换机的数据流，与ECS实例相关的安全组规则控制流入和流出ECS实例的数据流。网络ACL和安全组的基本差异如下表所示。对比项 网络ACL 安全组 运行范围 在交换机级别运行。在ECS实例...
基本概念
动态数据源：如从上下文中获取某个数据、从数据库读取某个数据、从逻辑流获取某个数据。形式上是一个对象，通过API加载数据。事件：如保存当前的数据、删除当前的数据、跳转页面、触发某个逻辑流。形式上是一个对象。通过API触发相关的事件...
API概览
DescribeLiveDomainPushBpsData 调用DescribeLiveDomainPushBpsData获取推流域名的推流网络带宽监控数据。DescribeLiveDomainPushTrafficData 调用DescribeLiveDomainPushTrafficData获取推流域名的推流流量监控数据。...
视频点播VOD的审计事件
DescribeVodDomainBpsData 获取加速域名的网络带宽监控数据。DescribeVodDomainCertificateInfo 获取指定加速域名的证书信息。DescribeVodDomainCname 查询域名CNAME。DescribeVodDomainConfigs 查询域名配置。DescribeVodDomainDetail ...
配置SQL赋值节点
背景信息 SQL赋值节点赋予任务流获取表中数据作为下游节点的变量的能力。变量在任务节点中的应用如下：在单实例SQL节点中，变量可以作为表名，或用在筛选条件中。在脚本代码节点中，变量可以作为脚本的参数。在Lindorm文件检查节点中，变量...
智能对话机器人的审计事件
ListBotColdDsDatas 获取对话流冷⻔榜的数据。ListBotColdKnowledges 获取机器⼈冷⻔知识。ListBotDsDetails 获取对话流明细数据。ListBotHotDsDatas 获取对话流热⻔榜数据。ListBotHotKnowledges 获取机器⼈热⻔知识。...
数据流运维
您可以在数据流运维中心查看数据流的发布状态、发布详情、运行记录等。登录 数据管理DMS 5.0。在顶部菜单栏中，选择 集成与开发（DTS）>数据集成>离线集成。单击数据流名称，进入数据流详情页面。单击画布右上方 前往运维。在数据流运维...
发布数据流
完成数据流的配置或变更后，您需要通过发布操作将最新的数据流发布，有效避免部分变更未经确认被直接发布。登录 数据管理DMS 5.0。在顶部菜单栏中，选择 集成与开发（DTS）>数据集成>离线集成。单击数据流名称，进入数据流详情页面。可选：...
API概览
点播CDN API 标题 API概述 监控查询 监控查询 资源访问数据 资源访问数据 DescribeVodDomainTrafficData 查询加速域名的流量数据 调用DescribeVodDomainTrafficData获取加速域名的网络流量监控数据。DescribeVodDomainBpsData 查询加速域名...
CREATE STREAM
创建一张数据流表，表示一个无界的事件集合。数据流表仅支持新增数据，不支持更新数据和删除数据。数据流表中的最小单元为Record，Record有预定义的Schema。数据流表的物理数据存储在流存储的某个指定的Topic上，具体的存储格式可以在With...
视频直播的审计事件
DescribeLiveDomainPushBpsData 查询推流域名推流网络带宽监控数据。DescribeLiveDomainPushTrafficData 查询推流域名推流流量监控数据。DescribeLiveDomainPvUvData 查询直播域名PV和UV数据。DescribeLiveDomainRealTimeBpsData 获取域名1...
离线集成概述
数据管理DMS离线集成是一种低代码的数据开发工具，您可以组合各类任务节点，形成数据流，通过周期调度运行达到数据加工、数据同步的目的。支持的数据库类型 MySQL：RDS MySQL、PolarDB MySQL版、MyBase MySQL、PolarDB分布式版、AnalyticDB...
DROP STREAM
删除数据流表。语法 DROP STREAM(IF EXISTS)table_name;参数 参数 是否必选 说明 table_name 是 数据流表的名称。示例 DROP STREAM users_original;
创建数据流
在数据管理DMS离线集成中，可以组合各类任务节点，形成数据流，通过周期调度运行达到数据加工、数据同步的目的。本文介绍创建数据流和配置的方法。前提条件 支持的数据库类型：MySQL：RDS MySQL、PolarDB MySQL版、MyBase MySQL、PolarDB...
区域统计
步骤二：写入流数据 Lindorm流引擎完全兼容开源Kafka API，您可以通过Kafka开源客户端或脚本工具连接Lindorm流引擎并写入测试数据。以通过开源Kafka脚本工具写入为例。下载并安装Kafka脚本工具。具体操作，请参见 通过开源Kafka脚本工具...
包年包月
计费公式 在包年包月模式下，您按需选择数据流服务Confluent版本、磁盘容量等配置项完成实例购买，计费从您成功下单开始。数据流服务Confluent版本不同所产生的费用也会存在差异。计算资源：用于Broker读取数据或ksqlDB创建作业，按CU计量...
概述
背景信息 Flink核心是一个流式的数据流执行引擎，其针对数据流的分布式计算提供了数据分布、数据通信以及容错机制等功能。基于流执行引擎，Flink提供了更高抽象层的API以便您编写分布式任务。Flink（VVR）完全兼容开源Flink，相关内容请...
API概览
本产品（机器学习PAI-工作流/2021-02-02）的OpenAPI采用 ROA 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，...GetPipeline 获取工作流 获取Pipeline信息。ListPipelines 获取工作流列表 获取工作流列表。
iOS和Mac
onCaptureVideoSample为预览数据回调，在开始预览之后可收到数据流。onRemoteVideoSample为拉流数据回调，subscribe拉流成功后可收到数据流。预览视频裸数据写入本地yuv文件。{/开始订阅[_engine registerVideoSampleObserver];}-(void)...
配置转换组件
单击左上角的，在 新增数据流 对话框中，您需在 数据流名称 配置ETL任务名称，选择 开发方式 为 DAG。单击 确认。完成数据源信息的配置，配置方法请参见 配置源库信息。重要 需要配置两个源库。在页面左侧，将 表 Join 节点拖拽至页面右侧...
用户管理
作为集群安全的一部分，数据流服务Confluent提供了用户管理功能。您可以在用户管理页面完成新增用户、修改密码、删除用户等操作。本文介绍用户管理的具体操作步骤。查看用户列表 首先登录 流数据服务Confluent管控页，点击集群管理>进入...
SELECT
流引擎兼容Apache Flink SQL的SELECT语句。Apache Flink V1.17.1 SELECT语句详情如下表所示。...Top-N 去重 从数据流中去除重复的行数据。Deduplication 说明 如果您需要查看其它版本Queries语句，请注意切换到对应版本。
ACL授权
ACL授权主要有两种方式：使用数据流服务Confluent控制台实现ACL授权。本文详细介绍这一授权方式。使用Confluent CLI实现ACL授权。操作指引请参见 使用Confluent CLI进行ACL管理。管控侧ACL授权步骤 首先登录 流数据服务Confluent管控页，...
API说明
isNetworkPushing 获取当前网络推流状态。setCustomDetect 设置用户自定义视频人脸识别回调。setCustomFilter 设置用户自定义视频美颜回调。setCustomAudioFilter 设置用户自定义音频处理回调。getCurrentStatus 获取当前状态。...
直播推流接口说明
isNetworkPushing 获取当前网络推流状态。setCustomDetect 设置用户自定义视频人脸识别回调。setCustomFilter 设置用户自定义视频美颜回调。setCustomAudioFilter 设置用户自定义音频处理回调。getCurrentStatus 获取当前状态。...
数据质量：全流程的质量监控
数据质量以数据集（DataSet）为监控对象，支持监控MaxCompute数据表和DataHub实时数据流。当离线MaxCompute数据发生变化时，数据质量会对数据进行校验，并阻塞生产链路，以避免问题数据污染扩散。同时，数据质量提供历史校验结果的管理，...
外部数据
不管使用什么外部数据包装器，本数据库会要求外部数据包装器从外部数据源获取数据，或者在更新命令的情况下传送数据到外部数据源。访问远程数据可能需要在外部数据源的授权。这些信息通过一个用户映射提供，它基于当前的本数据库角色提供了...
配置源库信息
单击左上角的，在 新增数据流 对话框中，您需在 数据流名称 配置ETL任务名称，选择 开发方式 为 DAG。单击 确认。在页面左侧，将 输入/维表 MySQL 节点拖拽至页面右侧画布的空白区域。单击画布区域的 输入/维表 MySQL-1，根据页面信息配置...
INSERT INTO
数据流表支持写入新的数据行，本文介绍通过DML语句将值插入流表中。语法 INSERT INTO[catalog_name.][db_name.]stream_name VALUES values_row[,values_row.]values_row:(val1[,val2,.])参数说明 参数 是否必选 说明 catalog_name 否 目标...
用户价值
数据资源平台为用户提供了一站式数据资产定义、生产、管理与服务平台，提供企业级数据资产构建能力和一致性使用体验，助力客户快速构建数据智能平台，实现数据资源统一管理，挖掘潜在规律，优化业务决策，让大数据真正的驱动客户业务。...
应用场景
实时数据通道 1.1 接入多种异构数据并投递到下游多种大数据系统 通过数据总线，您可以实时接入APP、WEB、IoT和数据库等产生的异构数据，统一管理，并投递到下游的分析、归档等系统，构建清晰的数据流，让您更好的释放数据的价值。...
API概览
DescribeVsDomainReqBpsData 获取域名网络请求监控数据 获取域名网络请求监控数据。DescribeVsDomainTrafficData 获取域名流量数据 获取域名流量数据。DescribeVsDomainReqTrafficData 获取 vs 域名请求流量数据 获取 vs 域名请求流量数据...
DTS订阅通道
本文档主要介绍如何添加DTS数据源以及配置数据源的参数获取。前提条件 已购买数据通道服务LTS，具体操作，请参见 开通LTS。操作步骤 登录 HBase控制台。在 集群列表 页，单击BDS目标实例ID。在 基本信息 页，单击 UI访问 区域中 BDS，进入 ...
常用管理
报错类型 说明 组件数据获取失败 组件请求数据源发生错误时，产生该报错。数据源的请求可能发生在组件首次加载时、组件自动更新时和全局变量触发更新时等。过滤器执行错误 组件请求数据源成功返回数据后，经过过滤器时产生报错，将记录为...
心选市场售卖
本文介绍如何购买流数据服务Confluent商品。购买流程 在阿里云云市场流数据服务Confluent商品售卖页中点击“立即购买”，跳转至流数据服务Confluent集群创建管控页。在流数据服务Confluent集群创建管控页进行集群配置和商品购买。操作步骤 ...
通过开源Kafka客户端写入Lindorm流引擎数据
指定数据流表的物理数据存储在某个Topic上 String topic="log_topic;props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");props.put(ProducerConfig.VALUE_SERIALIZER_CLASS...
- 产品推荐
- 这些文档可能帮助您