检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Topic名称 选择要写入数据的Topic名称。 Key 填写消息的Key值,表示消息存储在指定分区,可以当成有序消息队列使用。如果Key为空,则消息分布式存储在不同的消息分区。 元数据 定义写入到目标端Kafka消息的数据字段。源端有多少个字段需要集成,则目标端需要定义相同个数的元数据。
缓存时间(秒) 填写认证结果的缓存时间。值为0时代表不缓存,最大支持3600秒。 宽松模式 开启后,当自定义函数服务不可用(与自定义函数服务建立连接失败或者自定义函数服务返回5xx响应)时,ROMA Connect仍然接受客户端请求。 身份来源 添加用于认证的请求参数,支持添加Header参数和Query参数。
选择日志流所在的日志组。 如果没有可选的日志组,单击“查看日志组”,跳转到云日志服务管理控制台,并创建一个日志组,具体操作请参考创建日志组。 日志流 选择API调用日志要存储的日志流。 如果没有可选的日志流,单击“查看日志流”,跳转到云日志服务管理控制台,并创建一个日志流,具体操作请参考创建日志流。
消息管理 查询消息 重发消息 父主题: 消息集成API
更新网关子设备状态 主题Topic Topic /v1/devices/{gatewayId}/topo/update 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 deviceStatuses
getPlainCertificate(String key) 解密密码箱中证书密码的key值 输入参数 key:证书密码的key值 返回信息 返回解密后的证书密码消息体,消息体如下格式: { "cipherType": "CERTIFICATE", "passphrase": "xxx", "privateKey":
c发送的实际消息内容,一行为一条消息。 在ROMA Connect实例控制台选择“消息集成MQS > 消息查询”,进入消息查询页面。 单击“高级搜索”展开高级搜索框。 输入搜索条件,然后单击“搜索”,查询客户端发送的消息记录。 “Topic名称”选择步骤一:创建消息Topic中创建的消息Topic。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 最小长度:1 最大长度:100000 表3 请求Body参数 参数 是否必选
查询消息 功能介绍 查询消息的偏移量和消息内容。 先根据时间戳查询消息的偏移量,再根据偏移量查询消息内容。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /
Key)对调用请求内容进行签名认证。 Site实例中不支持IAM认证开发。 调用接口步骤 获取Token。 请参考《统一身份认证服务 API参考》的“获取用户Token”接口,获取Token。 请求响应成功后在响应消息头中包含的“X-Subject-Token”的值即为Token值。 请求内容示例如下: POST
ROMA.15019 Invalid VPC CIDR. 虚拟私用云的cidr无效。 使用cidr合法的虚拟私用云。 400 ROMA.15020 Failed to invoke the ECS service. 调用ECS服务失败。 提供实例ID信息,并联系技术支持工程师协助解决。
partition 是 Integer 分区。 message_offset 是 Number 消息偏移量。 consumer_key 否 String 应用Key。在该消息头中添加一个consumer_key的消息头。 响应参数 状态码: 200 表5 响应Body参数 参数 参数类型 描述 topic
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 表3 请求Body参数 参数 是否必选 参数类型 描述 name 否 String
购买公网NAT网关,VPC和子网选择实例所在的VPC及子网,其他根据业务需求配置。 图1 购买公网NAT网关 设置NAT网关规则,添加SNAT规则,使用场景选择虚拟私有云,网段选择RCU实例所在的子网,并绑定公网IP。 图2 添加SNAT网关规则 父主题: 附录
消息集成 向Topic生产的消息是否有长度限制? MQS支持的Kafka服务端版本是多少?
消息系统 ActiveMQ ArtemisMQ IBM MQ Kafka 父主题: 连接器
添加网关子设备 主题Topic Topic /v1/devices/{gatewayId}/topo/add 消息发送方 边设备 消息接收方 物联网平台 参数说明 字段名 必选/可选 类型 参数描述 mid 必选 Integer 命令ID。 deviceInfos 必选 List<DeviceInfos>
删除网关子设备 主题Topic Topic /v1/devices/{gatewayId}/topo/delete 消息发送方 物联网平台 消息接收方 边设备 参数说明 字段名 必选/可选 类型 参数描述 id 必选 Integer 删除子设备命令ID。 deviceId 必选 String
完成后单击“下一步”,定义后端服务。 定义后端服务 配置默认后端的基础定义。 FunctionGraph依赖于函数工作流服务FunctionGraph,若当前环境中未部署FunctionGraph服务,则后端服务类型FunctionGraph不可用。 表3 API后端服务配置 后端服务类型 参数 配置说明
sh进行处理。 ELK部署在独立服务器中,ELK的Logstash接收到日志数据后,根据设置的过滤解析规则,对日志数据进行拆分和过滤,然后将解析后的日志数据发送到ELK的ElasticSearch进行存储。 ELK的ElasticSearch接收到日志数据后,生成日志数据的索引并