产品优势

产品优势

  • 简单易用

    在线SQL编辑平台编写Stream SQL,定义数据流入、数据处理、数据流出,快速便捷实现业务逻辑;用户无需关心计算集群, 无需学习编程技能,降低流数据分析门槛
  • 独享集群

    全托管模式,自动弹性伸缩,用户完全不感知计算集群。提供共享集群和独享集群两种模式,独享集群与其他租户和共享集群完全物理隔离,并支持配额限制管理
  • 按需计费

    按资源使用量计费,用多少算多少,定价单位是CU(Compute Unit,1CU=1核CPU+4G内存),用户选定CU数,按时长计费
  • 高吞吐低时延

    采用Apache Flink的Dataflow模型,完全的实时计算框架。采用高性能计算资源,从用户自建的Kafka、MRS-Kafka、DMS-Kafka消费数据,单SPU每秒吞吐1千~2万条消息,不同场景的吞吐量有差异

主要功能

主要功能

  • StreamingML

    提供多种流式机器学习方法对数据进行实时分析与预测,用户仅需编写SQL调用相关函数便可实现数据统计,异常检测,实时聚类,时间序列分析等场景
    提供多种流式机器学习方法对数据进行实时分析与预测,用户仅需编写SQL调用相关函数便可实现数据统计,异常检测,实时聚类,时间序列分析等场景
  • 地理位置分析

    提供地理位置分析函数对地理空间数据进行实时分析,用户仅需编写SQL便可实现例如偏航检测,电子围栏等地理分析场景
    提供地理位置分析函数对地理空间数据进行实时分析,用户仅需编写SQL便可实现例如偏航检测,电子围栏等地理分析场景
  • CEP SQL

    提供基于Match Recognize的模式匹配检测,帮助业务人员使用SQL实现基于复杂事件规则的异常检测业务。典型应用场景如欺诈检测、车辆异常行为检测、工业设备异常运行状态检测等
    提供基于Match Recognize的模式匹配检测,帮助业务人员使用SQL实现基于复杂事件规则的异常检测业务。典型应用场景如欺诈检测、车辆异常行为检测、工业设备异常运行状态检测等
  • 可视化

    提供多种图表类型实时展示作业数据输出,用户可以通过API网关服务自由访问作业数据,接入自定义工作流中
    提供多种图表类型实时展示作业数据输出,用户可以通过API网关服务自由访问作业数据,接入自定义工作流中

应用场景

  • 实时流分析场景

  • 物联网IoT场景

实时流分析场景

实时流分析场景

提供易用、低时延、高吞吐的实时流分析服务。支持Stream SQL和用户自定义作业做流分析

优势

易用

在线编辑Stream SQL,丰富的SQL函数满足复杂业务需要

完全托管

用户完全不感知计算集群,聚焦流分析本身

按需计费

作业选定SPU资源量,按时长计费,精确到秒

建议搭配使用

物联网IoT场景

物联网IoT场景

物联网设备或边缘设备,上传数据到数据接入服务(DIS)或者其他云存储服务,Cloud Stream直接从DIS读取数据,实时分析数据流(故障检测、数据清洗、统计分析、指标预警等等),实时把流分析结果持久化或推送告警通知

优势

丰富的IoT SQL函数

区域检测函数、偏航检测函数、相对位置判断等常用的IoT函数

高吞吐低时延

使用Apache Flink执行引擎 ,完全的实时计算框架

安全隔离

租户之间完全隔离,确保数据安全

建议搭配使用

新特性

功能描述

功能描述

  • 丰富的StreamSQL在线分析能力

    支持window、join等聚合函数,用SQL表达业务逻辑,简便快捷实现业务
    支持window、join等聚合函数,用SQL表达业务逻辑,简便快捷实现业务
  • 低时延高吞吐

    从DIS中读取数据,服务支持自然反压机制,支持高吞吐压力;毫秒级延迟,满足实时计算的业务场景
    从DIS中读取数据,服务支持自然反压机制,支持高吞吐压力;毫秒级延迟,满足实时计算的业务场景
  • 安全可靠

    租户安全机制保障,确保作业安全运行
    租户安全机制保障,确保作业安全运行
  • 分布式实时计算

    支持大规模集群计算,集群弹性伸缩,节省成本
    支持大规模集群计算,集群弹性伸缩,节省成本

注册华为云账号,即刻开启免费云服务

立即注册