检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
法。 配置参数说明 表1 配置参数 参数 配置说明 allow origin Access-Control-Allow-Origin响应头,指定允许访问API的外域URI,多个URI之间使用英文逗号隔开。 对于未携带身份凭证的请求,可以把参数值设置为“*”,表示允许来自所有域的访问请求。
d} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 instance_id 是 String 实例编号 api_id 是 String API的编号 请求参数 表2 请求Header参数
Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“MRS HBase”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数
Connect根据您选择的RCU(ROMA Compute Unit,ROMA计算单元)数量和使用时长计费。具体收费介绍,请参考价格详情。 表1 新版ROMA Connect计费项 计费项 计费说明 RCU ROMA计量单元,根据购买的RCU数量和使用时长计费。 带宽(可选) 如有公网访问ROMA
200 表4 响应Body参数 参数 参数类型 描述 name String Topic名称。 状态码: 400 表5 响应Body参数 参数 参数类型 描述 error_code String 错误码。 error_msg String 错误信息。 状态码: 403 表6 响应Body参数
favorite Boolean 是否收藏应用,收藏的应用会在列表里优先显示。 表5 created_user 参数 参数类型 描述 user_id String 创建应用的用户ID。 user_name String 创建应用的用户名称。 表6 last_updated_user 参数 参数类型
strings 绑定的API编码列表。 数组长度:1 - 500 响应参数 状态码: 201 表4 响应Body参数 参数 参数类型 描述 attached_plugins Array of PluginApiAttachInfo objects 绑定插件信息列表。 表5 PluginApiAttachInfo
en的值)。 表3 请求Body参数 参数 是否必选 参数类型 描述 env_id 是 String 绑定API的环境编码。 plugin_ids 是 Array of strings 绑定的插件编码列表。 数组长度:1 - 500 响应参数 状态码: 201 表4 响应Body参数
favorite Boolean 是否收藏应用,收藏的应用会在列表里优先显示。 表5 created_user 参数 参数类型 描述 user_id String 创建应用的用户ID。 user_name String 创建应用的用户名称。 表6 last_updated_user 参数 参数类型
设备物理标识“deviceId”,数据类型为“String”。 车位状态属性数据“status”,数据类型为“String”,值为“0”表示未停车,值为“1”表示已停车。 表3 服务属性配置 参数 deviceId属性配置说明 status属性配置说明 属性名称 设备上报属性参数的名称,此处填写为“deviceId”。
确保消息生产与消费客户端与ROMA Connect实例的消息集成MQS连接地址网络互通。您可以在ROMA Connect实例控制台的“实例信息”页面查看消息集成MQS连接地址。 如果使用内网地址连接,则客户端与ROMA Connect实例应在同一VPC内。若客户端和ROMA Connect
实例上的“查看控制台”,进入实例控制台。 在“实例信息”页面选择“配置参数”页签,并找到级联功能开关参数“cascade”。 单击参数右侧的“编辑”,把参数运行值设置为“on”,然后单击“保存”,打开级联功能开关。 单击参数左侧的“”,展开并配置级联相关配置参数。 表1 子公司实例配置
创建用于后端认证的函数后端 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。 在左侧的导航栏选择“服务集成 APIC > 自定义后端”,在“后端列表”页签中单击“创建后端”。 在创建后端页面配置后端信息,完成后单击“立即创建”。 “后端请求方法”必须为“POST”。
求参数中添加了用于签名的X-Sdk-Date头和Authorization头。 var opts = sig.Sign(r) 访问API,查看访问结果。如果使用https访问,则将“http.request”改为“https.request”。 var req=http.request(opts
引入Kafka客户端 MQS基于Kafka社区版本1.1.0、2.7,您可以在ROMA Connect实例控制台的“实例信息”页面,在“MQS基本信息”下查看Kafka版本信息。Python开源客户端的版本使用请参见客户端版本使用建议。 执行以下命令,安装对应版本的Python Kafka客户端:
与“API流量限制”配合使用,表示单位时间内API被调用的次数上限。 与“用户流量限制”配合使用,表示单位时间内的单个用户调用API的次数上限。 与“凭据流量限制”配合使用,表示单位时间内的单个凭据调用API的次数上限。 与“源IP流量限制”配合使用,表示单位时间内的单个IP地址调用API的次数上限。
id}/throttles 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 instance_id 是 String 实例ID 请求参数 表2 请求Header参数 参数
编辑log4j.properties 修改日志存储目录: log.directory=D://workspace/logs 运行示例工程,查看消息生产与消费样例。 消息生成与消费的Main方法在RestMain.java中,以Java Application的方式运行即可。 示例代码解读
引入Kafka客户端 MQS基于Kafka社区版本1.1.0、2.7,您可以在ROMA Connect实例控制台的“实例信息”页面,在“MQS基本信息”下查看Kafka版本信息。Go开源客户端的版本使用请参见客户端版本使用建议。 执行以下命令,安装对应版本的Go Kafka客户端。 go get
/filebeat/docker-compose.yml 其中,log目录用于存储Filebeat收集到的日志数据以及其它元数据信息,即使容器Filebeat被删除并重新启动,会继续读取该目录中的内容(如registry),并在收集数据时更新该目录,这样可确保Filebeat只收集新的日志数据,避免将已经发送过的数据再次发送。