检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Connect实例控制台，在“服务集成 APIC > 凭据管理”的“SDKs”页签中下载SDK。 导入工程 打开IntelliJ IDEA，在菜单栏选择“File > New > Project”。 弹出“New Project”对话框，选择“Python”，单击“Next”。 图2 New Project
导入 如果本地已存在文件，可以直接在“产品”页签单击“导入”，即可导入包含产品信息的文件。 文件模板获取方式：在界面创建一个产品，选中该产品，单击导出键导出csv文件，根据需要导入的产品修改csv文件的内容。 导出/导出所有产品 导出单个或多个产品信息的csv文件。 如果导出单个或
务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。Kafka的主要优点是可扩展性、高吞吐量、低延迟、可靠性和持久性。它被广泛应用于大数据处理、实时数据流处理、日志收集等领域。 创建Kafka连接
接入OBS数据源 概述 ROMA Connect支持把OBS（对象存储服务）作为一个数据源，并用于数据集成任务。在使用OBS数据源前，您需要先接入数据源。 前提条件 每个接入的数据源都要归属到某个集成应用下，在接入数据源前您需要有可用的集成应用，否则请提前创建集成应用。 操作步骤
数据集成到目标端的一个数据表中。 数据集成任务的配置分为任务基本信息、制定计划（可选）、源端信息、目标端信息、Mapping信息和异常数据存储（可选）、任务完成后执行（可选）几个部分，本节及接下来的几个小节将对这几部分分别进行介绍。本节主要提供数据集成任务基本信息和任务计划的配置说明。
消息预览图链接。 表4 机器人发送文件消息 参数 说明 群聊ID 从钉钉的创建企业内部群或创建场景群接口获取。对于已存在的群，可以用钉钉的根据corpid选择会话JSAPI获取。 媒体文件ID 通过上传媒体文件接口，获取media_id参数值。 文件名称 发送的文件名称。 文件类型 支持xlsx
是否开启公网访问，开启时publicip_id字段必填。 publicip_id String 实例绑定的弹性公网地址ID。 publicip_address String 实例绑定的弹性公网地址。 status String 实例运行状态。 error_code String 错误码。
务器。生产者将数据发布到Kafka集群，消费者从Kafka集群订阅数据并进行处理，代理服务器则是Kafka集群中的核心组件，负责处理消息的存储和转发。Kafka的主要优点是可扩展性、高吞吐量、低延迟、可靠性和持久性。它被广泛应用于大数据处理、实时数据流处理、日志收集等领域。 创建Kafka连接
找到原来已下载的AK/SK文件，文件名一般为：credentials.csv。 如下图所示，文件包含了租户名（User Name），AK（Access Key Id），SK（Secret Access Key）。 图1 credential.csv文件内容 AK/SK生成步骤： 注册并登录管理控制台。
支持消息数据高可靠 支持消息持久化，多副本存储机制。副本间消息同步、异步复制，数据同步或异步落盘多种方式供您自由选择。 使用流程 使用ROMA Connect进行消息集成的流程如下图所示。 图1 业务使用流程 已创建实例和集成应用。 创建Topic 创建用于存储消息的Topic，供消息生产方发布消息和供消息消费方订阅消息。
找到原来已下载的AK/SK文件，文件名一般为：credentials.csv。 Secret Access Key 当前账号的SK（Secret Access Key）。请参考访问密钥获取SK，如果已生成过AK/SK，找到原来已下载的AK/SK文件，文件名一般为credentials
KafkaConsumer(config) var records = consumer.consume(topic, 5000, 10); var res = [] var iter = records.iterator() while (iter.hasNext())
topic：要生产消息的Topic名称。 消费消息 SASL认证方式 注意，加粗内容需要替换为实例自有信息。 using System; using System.Threading; using Confluent.Kafka; class Consumer { public
找到原来已下载的AK/SK文件，文件名一般为：credentials.csv。 Secret Access Key 当前账号的SK（Secret Access Key）。请参考访问密钥获取SK，如果已生成过AK/SK，找到原来已下载的AK/SK文件，文件名一般为credentials
查询Topic列表 创建Topic 修改Topic 删除Topic 批量删除Topic 导入Topic 导出Topic 下载证书 查询topic的磁盘存储情况 父主题： 消息集成API
流任务的结束时间。 运行ID 流任务的运行ID。 运行时间 流任务的运行时间。 状态 流任务的运行状态。 （可选）配置访问日志，实现异常监控日志的存储。 如果组合应用未启动，请单击“启动并配置运行记录”，选择一个实例启动此组合应用。 如果组合应用已启动，单击“点击开启”弹出“运行记录配置”窗口，然后配置日志接入信息。
Connect内分配唯一的ID和密钥，使设备可以连接到ROMA Connect上的LINK中。 数据转发 ROMA Connect不会直接存储设备上报的数据，您需要配置数据转发规则，把设备数据转发到其他服务进行存储。可以把数据转发到ROMA MQS，也可以转发到Kafka、DIS等其他服务。 接入设备 设备在集成MQTT客户端后即可接入到ROMA
Topic主题 日志要推送的目标Kafka Topic名称。 Key 填写消息的Key值，表示消息存储在Kafka的指定分区，可以当成有序消息队列使用。如果Key为空，则消息分布式存储在不同的消息分区。 失败重试分配 日志推送到Kafka失败后的重试配置。 重试次数：失败后的重试次数，范围为0-5次。
找到原来已下载的AK/SK文件，文件名一般为：credentials.csv。 Secret Access Key 当前账号的SK（Secret Access Key）。请参考访问密钥获取SK，如果已生成过AK/SK，找到原来已下载的AK/SK文件，文件名一般为credentials
Connect。 前提条件 ROMA Connect与停车场设备和停车场管理系统的网络互通。若通过公网互通，ROMA Connect实例需绑定弹性IP。 停车场设备包含车位感应设备和进出门闸设备，配置过程类似，此处以车位感应设备的配置为例进行说明。 操作步骤 创建集成应用。 登录ROMA
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
