检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Flink DataStream样例程序(Scala) 功能介绍 实时统计连续网购时间超过2个小时的女性网民信息,将统计结果直接打印出来。 代码样例 下面代码片段仅为演示,完整代码参见FlinkStreamScalaExample样例工程下的com.huawei.bigdata.flink
Streaming对接Kafka样例程序(Scala) 功能介绍 使用Structured Streaming,从kafka中读取广告请求数据、广告展示数据、广告点击数据,实时获取广告有效展示统计数据和广告有效点击统计数据,将统计结果写入kafka中。 代码样例 下面代码片段仅为演示,具体代码参见:com.huawei
Scala样例代码 功能介绍 实时统计连续网购时间超过半个小时的女性网民信息,将统计结果直接打印或者输出写入到Kafka中。 Spark Streaming Write To Print代码样例 下面代码片段仅为演示,具体代码参见com.huawei.bigdata.spark.examples
Streaming对接Kafka样例程序(Scala) 功能介绍 使用Structured Streaming,从kafka中读取广告请求数据、广告展示数据、广告点击数据,实时获取广告有效展示统计数据和广告有效点击统计数据,将统计结果写入kafka中。 代码样例 下面代码片段仅为演示,具体代码参见:com.huawei
Canal Format 功能描述 Canal是一个 CDC(ChangeLog Data Capture,变更日志数据捕获)工具,可以实时地将 MySQL 变更传输到其他系统。Canal 为变更日志提供了统一的数据格式,并支持使用 JSON 或 protobuf序列化消息(Canal
Canal Format 功能描述 Canal是一个 CDC(ChangeLog Data Capture,变更日志数据捕获)工具,可以实时地将 MySQL 变更传输到其他系统。Canal 为变更日志提供了统一的数据格式,并支持使用 JSON 或 protobuf序列化消息(Canal
概述 APM探针通过字节码增强技术进行调用埋点,运行在应用所在的服务器上,实时采集应用性能相关的数据。 安装APM 探针是使用APM服务的前提,详细操作参见为JAVA应用手工安装Agent。 APM支持对租户使用的探针数量进行统计,详细操作参见探针统计。 父主题: 探针管理
通过云日志服务查看慢日志 通过云日志服务进行分析日志、搜索日志、日志可视化、下载日志和查看实时日志等操作。 查看LTS慢日志 实例已经配置了访问日志,操作详情请参见日志配置管理。 在页面左上角单击,选择“管理与监管 > 云日志服务”,进入云服务日志页面。 在“日志组列表”区域,选
查看Kafka数据生产消费详情 操作场景 用户可以通过KafkaUI查看Topic详情、修改Topic Configs、增加Topic分区个数、删除Topic,并可实时查看不同时段的生产数据条数。 安全模式下,KafkaUI对查看Topic详情操作不作鉴权处理,即任何用户都可以查询Topic信息;对于修改Topic
ClickHouse安装部署依赖ZooKeeper服务。 ClickHouse通过Flink流计算应用加工生成通用的报表数据(明细宽表),准实时写入到ClickHouse,通过Hive/Spark作业加工生成通用的报表数据(明细宽表),批量导入到ClickHouse。 ClickH
通过云日志服务查看审计日志 通过云日志服务进行分析日志、搜索日志、日志可视化、下载日志和查看实时日志等操作。 查看LTS审计日志 实例已经配置了访问日志,操作详情请参见日志配置管理。 在页面左上角单击,选择“管理与监管 > 云日志服务”,进入云服务日志页面。 在“日志组列表”区域
包含另存为其他格式文件、查看XML、管理流程编辑视图等操作。 在线编辑区 位于流程编辑页面中央,是可视化设计流程的核心模块。在左侧工具栏的工具面板中,将所需的流程工具拖拽到在线编辑区内;然后根据已明确的业务流程,单击在线编辑区内的流程工具,设置流程工具间的连接、属性、样式等,具体操
本地Internet接入)、全局接口管理、SSID、全局射频、Portal认证、安全策略、流量策略、认证授权策略、用户在线控制策略、Portal页面推送策略、监控设置、语音设备OUI、VLAN信息、无线安全、攻击防范、全局IoT、蓝牙、DHCP、风暴抑制、MAC黑白名单、NAT日志、SA升级策略”特性支持克隆。
aster进程只用来向YARN集群申请资源。 Spark Streaming原理 Spark Streaming是一种构建在Spark上的实时计算框架,扩展了Spark处理大规模流式数据的能力。当前Spark支持两种数据处理方式:Direct Streaming和Receiver方式。
物联网平台有两种命令下发机制: 立即下发:平台收到命令后立即下发给设备,保证实时性,不保证串行性。 缓存下发:平台收到命令后缓存起来,在设备可达时排队串行下发,平台收到前一个命令的响应(模组自动回复的ACK)才会下发后一个命令,保证串行性,不保证实时性。 此接口适用于使用LWM2M/CoAP协议接入的设备,例如NB-IoT设备。
视频直播 视频直播 在互动直播场景中,成千上万个房间并发直播,人工审核所有直播内容几乎不可能。基于内容审核的图像检测能力,可对所有房间内容实时监控,识别可疑房间并进行预警 优势 准确率高 基于改进的深度学习算法,内容检测准确率高 处理速度快 基于大规模GPU集群,快速识别敏感信息 建议搭配使用
策略和API本身相互独立,只有为API绑定策略后,策略才对API生效。为API绑定策略时需指定发布环境,策略只对指定环境上的API生效。 策略的绑定、解绑、更新会实时生效,不需要重新发布API。 API的下线操作不影响策略的绑定关系,再次发布后仍然会带有下线前绑定的策略。 如果策略与API有绑定关系,则策略无法执行删除操作。
概述 欢迎使用IoT数据分析服务,本服务提供丰富的数据分析能力,包括实时分析,时序分析,数字资产分析,您可以使用本文档提供的API对IoT数据分析服务进行相关操作,如创建资产模型、查看模型、查询资产属性等。支持的全部操作请参见 API概览。 父主题: 使用前必读
配置远程通知规则 前提条件 已完成远程通知的相关配置,配置入口为:在主菜单中选择“系统 > 系统设置 > 远程通知”。 已具备“设置远程通知规则”操作权限。 背景信息 远程通知邮件和短信使用第三方服务器和设备进行发送,发送能力(如到达用户邮箱的时延等)会受到第三方服务器和设备影响。
指定某个数字资产的授权用户,授权用户拥有转移数字资产的权利。每个tokenId只可有一个授权用户。开发者可根据业务需要使用,例如设置代理操作员,无需所有者实时响应等。 调用方法 public String approve(String collectionIndex, String operator