检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
业务画像-画像更新 业务画像-画像更新页面,左侧选择对应的目录,右侧展示对应的标签,单击执行更新,更新成功后,可查看详情和历史 图1 画像更新1 更新成功后,标签创建页面,对应标签覆盖数量为中标的数量,单击详情可查看标签的基础信息、标签评估分析和具体明细数据 图2 画像更新2 图3
Kafka实例是否需要创建消费组、生产者和消费者? “auto.create.groups.enable”为“true”时,不需要单独创建消费组、生产者和消费者,在使用时自动生成,实例创建后,直接使用即可。 “auto.create.groups.enable”为“false”时
分区数较多且每个消费者开启多个线程的情况下。 如图1所示,Topic含有多个分区,消费组中有多个消费者同时进行消费,每个线程均为长连接。当Topic中消息较少或者没有消息时,连接不断开,所有消费者不间断地拉取消息,这样造成了一定的资源浪费。 图1 Kafka消费者多线程消费模式 解决方案
单击“选择数据”左下方的“特征画像”。 新增“特征画像”内容,如图1所示。 图1 特征画像 单击“特征画像”代码框左侧的图标,运行代码。 通过运行结果左侧两个图可以直观的看一下原始数据和数据的密度分布图。运行结果右侧的参数说明,如表1所示。 表1 特征画像参数说明 参数 说明 设备数
配置RabbitMQ单一活跃消费者 单一活跃消费者(Single Active Consumer)表示队列中可以注册多个消费者,但是只允许一个消费者消费消息,只有在此消费者出现异常时,才会自动转移到另一个消费者进行消费。单一活跃消费者适用于需要保证消息消费顺序性,同时提供高可靠能力的场景。
列表页面。 单击待查看消费者列表的消费组名称,进入消费组详情页。 在“消费者列表”页签,查看消费者列表。 在消费者列表中,可以查看消费者ID、消费者地址和客户端ID。 (可选)如果需要查询某个消费者,在搜索框中,输入消费者ID,按“Enter”。 查看消费者列表(客户端) 未开启
查询消费者列表 功能介绍 查询消费组内消费者列表 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/{project_id}/instances/{instance_id}/groups/{group}/clients 表1 路径参数 参数 是否必选 参数类型
查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址,当客户端连接RocketMQ消费消息时,可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时,才可以查看消费者连接地址。 前提条件 已创建消费组,且消费组中已存在消费者。 已创建Topic。
如果消息组中没有在线的消费者(如empty状态),是否14天后会自动被删除? 消息组中没有在线的消费者(如empty状态),14天后是否会自动被删除与offsets.retention.minutes、auto.create.groups.enable参数有关: 2023年4月25日前创建的实例,auto
实现RabbitMQ节点重启后消费者自动重连 方案概述 RabbitMQ的amqp-client虽然自带重连机制,但是自带的重连机制只会重试一次,重连失败后就不再执行。这时如果消费者没有做额外的重试机制,那么这个消费者就彻底断开与服务端的连接,无法消费消息。 amqp-clien
未发布的数据资产可以提供给数据消费者使用吗 未发布的数据资产不可以提供给数据消费者使用。基于数据安全要求(华为公司以及各国各地区的数据安全法规,比如欧盟GDPR)和公有云部署特点(数据上Internet没有网络隔离的情况),若要使用和消费数据,必须先对数据资产进行发布,再通过订阅数据资产来进行数据使用。
topics”的报错。 图1 消费者访问权限 处理方法: 如果业务要求所有消费者在同一个消费组内,即group.id相同,解决方法:为所有消费者授权相同的Topic访问权限。 如果消费者不需要在同一个消费组内,解决方法:修改group.id,让每个消费者单独在一个消费组内。 父主题:
于数据消费者。 数据管理者可以对当前租户下治理的数据进行管理,例如:发布数据集、配置数据集授权、审批数据集订阅申请等,也可以对当前租户下发布的所有数据集和其他租户下发布的外部公开及已授权的秘密、机密或绝密的数据集进行消费,例如:订阅数据集、下载数据集到OBS桶等。数据消费者可以对
Kakfa消费者读取单条记录过长问题 问题背景与现象 和“Kafka生产者写入单条记录过长问题”相对应的,在写入数据后,用户开发一个应用,以消费者调用新接口(org.apache.kafka.clients.consumer.*)到Kafka上读取数据,但读取失败,报异常大致如下:
查询播放画像信息接口 功能介绍 查询播放画像信息。 最大查询跨度1天,最大查询周期31天。 该接口仅支持查询FLV和RTMP流的在线人数。 接口约束 该接口暂只支持查询部署在新版视频直播服务上的域名的相关数据(不包含“华北-北京一”)。此约束条件仅适用于中国站。 调用方法 请参见如何调用API。
于数据消费者。 数据管理者可以对当前租户下治理的数据进行管理,例如:发布数据集、配置数据集授权、审批数据集订阅申请等,也可以对当前租户下发布的所有数据集和其他租户下发布的外部公开及已授权的秘密、机密或绝密的数据集进行消费,例如:订阅数据集、下载数据集到OBS桶等。数据消费者可以对
Pod实例画像的算法。 profilePeriod Pod实例画像的周期,单位为秒,支持范围是60-2592000,即1分钟到1个月。对于指标采集累积时长未达到周期的Pod,将使用Pod资源请求量来计算节点的资源用量。 因此,初始启用基于Pod实例画像的算法,未达到画像周期之前,节点的超卖量会为0。
未发布的数据资产可以提供给数据消费者使用吗 未发布的数据资产不可以提供给数据消费者使用。基于数据安全要求(华为公司以及各国各地区的数据安全法规,比如欧盟GDPR)和公有云部署特点(数据上Internet没有网络隔离的情况),若要使用和消费数据,必须先对数据资产进行发布,再通过订阅数据资产来进行数据使用。
标签应用-画像查询与群体分析 画像查询 单击标签应用-画像查询,上方左侧选择对应的主体,右侧进行搜索,则下方左侧显示该搜索值的基本信息,下方右侧显示中标画像(当搜索值同时中标该主体下的多个标签时,则画像展示为多个) 图1 画像查询 群体分析 单击标签应用-群体分析,在群体分析界面
查看和重置Kafka消费进度 消费进度表示消费者的消费位置,本章节介绍如何查看和重置消费进度,重置消费进度即修改消费者的消费位置。 操作视频 本视频演示重置Kafka消费进度的操作。 约束与限制 重置消费进度可能会导致重复消费,请谨慎操作。 前提条件 Kafka实例不支持在线重置