检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"ip3:port3"], 'topic_name': 'topic_name', 'consumer_id': 'consumer_id' } print('start consumer') consumer = KafkaConsumer(conf['topic_name'],
间件,提供可靠、高效、可扩展的消息传递机制,支持多种消息协议和传输协议,如TCP、UDP、SSL、NIO等。ActiveMQ支持多种队列和主题模式,可以用于异步消息传递、发布/订阅、消息路由等场景。它还提供了可视化的管理界面,便于配置和监控,具有较高的可靠性和灵活性。Active
消息通知服务所在的区域。 项目 消息通知服务所在的项目。 主题 在消息通知服务创建的主题,指消息发布或客户端订阅通知的特定事件类型。 消息标题 给邮箱订阅者发送邮件时作为邮件主题。 消息内容 发送给订阅者的消息正文。 父主题: 华为云服务
MQTT 基本信息 可查看设备标识、在线状态、连接地址等。 Topic列表 根据产品标识、设备标识系统自动生成默认的Topic,即基础Topic。用户也可以根据实际情况自定义Topic,具体操作请参见为设备添加自定义Topic。 设备影子 设备影子是用于存储设备上报状态、上报值等信息,可通过列表和JSON文档的形式查看。
最大长度:100000 表3 请求Body参数 参数 是否必选 参数类型 描述 topic 是 String 通知发送的主题名,该主题需要在对应目的端中存在,例如如果目的端为MQS,则MQS中需要存在对应Topic。 最小长度:0 最大长度:64 status 是 Integer 启停状态,0-启用,1-停用。
配置模型地图 配置标注 配置检索 创建模型主题 父主题: 应用业务模型使用指导
介绍怎样创建数据集成普通任务 03:15 创建数据集成普通任务 应用与数据集成平台 ROMA Connect 介绍怎样创建Topic和为Topic授权 01:58 创建Topic和配置Topic授权 应用与数据集成平台 ROMA Connect 介绍怎样创建API和发布API 03:00 创建和发布API
设备管理 创建设备 创建设备自定义Topic 查询设备列表 查询设备Topic列表 查询实例信息 父主题: 设备集成API(V1)
Kafka通道的topic中的数据老化时间为6小时,可以等待脏数据被清理掉后启动任务。 删除原任务并重建,那么Kafka通道中的topic会被删除,脏数据会被清理掉。 对于组合任务,可以删除此表,启动任务后,等Writer端消耗掉此表的数据,再将表加回来重新采集。 父主题: 数据集成组合任务
填写连接器的描述信息,用于识别不同的连接器。 支持的动作 监听主题 监听队列 配置参数 表1 监听主题 参数 说明 主题名称 要监听的消息队列名称。 表2 监听队列 参数 说明 队列名称 要监听的消息队列名称。 父主题: 触发器
为分组级别时不允许配置产品。 最小值:1 最大值:99999999999999999 topic 是 String 主题,当设备ID为空时为产品级(设备分组级)主题,设备ID不为空时为设备级主题。 最小长度:0 最大长度:64 is_base64 否 Integer 是否payl
_address}:9292,通过指定实例接口查询rest_connect_address的IP地址。 URI GET /v1/topic/{topic_name}/group/{group_name}/messages?ack_wait={ack_wait}& time_wai
最小长度:0 最大长度:255 topic 是 String 目标数据源主题,destination_type值为0时,从MQS服务中获取已有Topic;destination_type值为1、2或3时, 从对应KAFKA类数据源中获取已有Topic。 最小长度:0 最大长度:64
其他 FTP 父主题: 连接器
开发说明 开发场景 开发规范 父主题: 服务集成开发指导
实例管理 查看实例详情 查看实例约束信息 父主题: 服务集成API
开发说明 开发场景 开发规范 父主题: 数据集成开发指导
创建ROMA Site协同版实例 准备资源 创建实例 父主题: 实例管理
规则引擎 配置数据转发规则 导入导出规则 父主题: 设备集成指导
实例特性管理 查看实例特性列表 实例配置特性 父主题: 服务集成API