云服务器内容精选

  • 响应示例 当URL存在时: { "callback_url": "http://xxxxxx:xx", "subscription_type": "DEVICE_ALARM", "create_time": "2021-03-30 14:34:50", "update_time": "2021-03-30 15:34:50", "auth_key": "xxxxxxx" } 当URL不存在时: {}
  • 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型 描述 callback_url String 支持http/https协议,最大长度为256英文字符 create_time String 创建时间 update_time String 更新时间 subscription_type String 订阅类型字段, 枚举值: DEVICE_ALARM 智能告警消息(含第三方告警),该消息的数据推送结构体设备智能告警消息结构体 DEVICE_EXCEPTION 设备异常消息,该消息的数据推送结构体设备异常告警消息结构体 DEVICE_UNBIND 设备解绑、套餐解绑数据,该消息的数据推送结构体设备解绑消息结构体 TARGET_DATA 目标TLV数据,该消息的数据推送结构体目标数据消息结构体 THIRD_DATA 第三方TLV数据,该消息的数据推送结构体三方数据消息结构体 VEHICLE_DATA 机非人TLV数据,该消息的数据推送结构体机非人消息结构体 HEAD_SHOULDER_DATA 头肩业务TLV数据,该消息的数据推送结构体头肩业务消息结构体 BEHAVIOR_ANALYSIS_DATA 行为分析TLV数据,该消息的数据推送结构体行为分析与人车物分离消息结构体 MICRO_CHECKPOINT_DATA 微卡口TLV数据,该消息的数据推送结构体微卡口数据推送结构体 auth_key String 鉴权密钥
  • URI GET /v1/{user_id}/messages/callback 表1 路径参数 参数 是否必选 参数类型 描述 user_id 是 String 用户ID:由数字组成,长度范围[15,25],获取方式参考获取user ID与下载AK/SK章节 表2 Query参数 参数 是否必选 参数类型 描述 subscription_type 是 String 订阅类型字段 枚举值: DEVICE_ALARM 智能告警消息(含第三方告警),该消息的数据推送结构体设备智能告警消息结构体 DEVICE_EXCEPTION 设备异常消息,该消息的数据推送结构体设备异常告警消息结构体 DEVICE_UNBIND 设备解绑、套餐解绑数据,该消息的数据推送结构体设备解绑消息结构体 TARGET_DATA 目标TLV数据,该消息的数据推送结构体目标数据消息结构体 THIRD_DATA 第三方TLV数据,该消息的数据推送结构体三方数据消息结构体 VEHICLE_DATA 机非人TLV数据,该消息的数据推送结构体机非人消息结构体 HEAD_SHOULDER_DATA 头肩业务TLV数据,该消息的数据推送结构体头肩业务消息结构体 BEHAVIOR_ANALYSIS_DATA 行为分析TLV数据,该消息的数据推送结构体行为分析与人车物分离消息结构体 MICRO_CHECKPOINT_DATA 微卡口TLV数据,该消息的数据推送结构体微卡口数据推送结构体
  • 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型 描述 callback_url String 支持http/https协议,最大长度为256常规字符 create_time String 创建时间 subscription_type String 订阅类型字段 枚举值: DEVICE_ALARM 智能告警消息(含第三方告警),该消息的数据推送结构体设备智能告警消息结构体 DEVICE_EXCEPTION 设备异常消息,该消息的数据推送结构体设备异常告警消息结构体 DEVICE_UNBIND 设备解绑、套餐解绑数据,该消息的数据推送结构体设备解绑消息结构体 TARGET_DATA 目标TLV数据,该消息的数据推送结构体目标数据消息结构体 THIRD_DATA 第三方TLV数据,该消息的数据推送结构体三方数据消息结构体 VEHICLE_DATA 机非人TLV数据,该消息的数据推送结构体机非人消息结构体 HEAD_SHOULDER_DATA 头肩业务TLV数据,该消息的数据推送结构体头肩业务消息结构体 BEHAVIOR_ANALYSIS_DATA 行为分析TLV数据,该消息的数据推送结构体行为分析与人车物分离消息结构体 MICRO_CHECKPOINT_DATA 微卡口TLV数据,该消息的数据推送结构体微卡口数据推送结构体
  • 功能介绍 配置用户消息通知URL(增加或者更新用户消息通知URL)。 配置回调 URL 时将通过 HTTP/HTTPS 请求的方式发送一条测试请求给用户服务器,用户服务器需要处理行业视频管理服务的回调请求,并尽快进行应答。 注意事项: 回调的方向是行业视频管理服务向用户服务器发起 HTTP/HTTPS POST 请求,为了获得更高的安全性,推荐您使用 HTTPS 通道发送请求; 行业视频管理服务回调用户服务器的超时时间为 1 秒,且没有重试。如果回调超时,则配置失败。为确保回调成功率,用户服务器应当尽可能加快回调处理速度,例如先发送回调应答,然后再处理具体业务逻辑; 确保回调 URL 的 IP 和端口公网可达,以及防火墙策略不限制外网访问,接口应支持application/json格式的数据 回调请求成功后,确保应答报文中的 HTTP 返回码为 200。 配置回调 URL 时,云服务端会访问该地址是否可用。访问请求体格式为: { "message_id": 1614936351275468803, // int64 或 long 整型 "test": true // boolean 类型 } 注意,在配置好回调 URL,还需要给设备开通接入调阅服务和行业数据流服务后,才能接收到告警数据。
  • 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 Access-Token 是 String 用户认证token,从获取用户认证token接口获取 表3 请求Body参数 参数 是否必选 参数类型 描述 callback_url 是 String 要添加的URL,支持http和https协议,长度在256常规字符以内,不支持中文,长度范围[1,256] subscription_type 是 String 订阅类型字段 枚举值: DEVICE_ALARM 智能告警消息(含第三方告警),该消息的数据推送结构体设备智能告警消息结构体 DEVICE_EXCEPTION 设备异常消息,该消息的数据推送结构体设备异常告警消息结构体 DEVICE_UNBIND 设备解绑、套餐解绑数据,该消息的数据推送结构体设备解绑消息结构体 TARGET_DATA 目标TLV数据,该消息的数据推送结构体目标数据消息结构体 THIRD_DATA 第三方TLV数据,该消息的数据推送结构体三方数据消息结构体 VEHICLE_DATA 机非人TLV数据,该消息的数据推送结构体机非人消息结构体 HEAD_SHOULDER_DATA 头肩业务TLV数据,该消息的数据推送结构体头肩业务消息结构体 BEHAVIOR_ANALYSIS_DATA 行为分析TLV数据,该消息的数据推送结构体行为分析与人车物分离消息结构体 MICRO_CHECKPOINT_DATA 微卡口TLV数据,该消息的数据推送结构体微卡口数据推送结构体 auth_key 否 string 鉴权密钥:给客户推送消息时,客户认证时使用,长度范围[6,18],该字段为非必填字段,但建议客户填写,有助于提高可靠性。 认证方式如下: 当配置了auth_key后,回调方会根据 (回调地址+"|"+时间戳+"|"+auth_key)用sha256算法做数字摘要。 在回调时,通过HEAD参数 "X-Ivm-Signature" 传递摘要,"X-Ivm-Timestamp"传递时间戳。设置方通过计算sha256(回调地址+"|"+时间戳+"|"+auth_key)进行认证,可参考告警推送消息体结构
  • 前提条件 删除消息前,请先在消费代码中设置“auto.offset.reset”参数。“auto.offset.reset”用来指定当Kafka中没有初始偏移量或者当前偏移量不存在(例如当前偏移量已被删除)时,消费者的消费策略。取值如下: latest:偏移量自动被重置到最晚偏移量。 earliest:偏移量自动被重置到最早偏移量。 none:向消费者抛出异常。 如果将此配置设置为latest,新增分区时,生产者可能会在消费者重置初始偏移量之前开始向新增加的分区发送消息,从而导致部分消息丢失。
  • 操作场景 本章节指导您通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。 分布式消息服务RocketMQ版提供三种消息查询的方法:按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询:查询某时间段内指定Topic下所有的消息。此方法属于范围查询,查询到的消息可能比较多。 按Message ID查询:查询指定Message ID的消息。此方法属于精确查找,可以快速查询到某一条消息。 按Message Key查询:查询指定Message Key的消息。此方法属于精确查找,可以快速查询到某一条消息。
  • 消息清理机制 无论消息是否被消费,RocketMQ的消息默认保留时间为48小时,最长保留时间为720小时。RocketMQ消息存储在CommitLog文件中,CommitLog文件大小为1GB,当一个CommitLog文件写满后,会生成一个新的CommitLog文件。RocketMQ删除消息是删除CommitLog文件,而不是删除一条消息。CommitLog文件为顺序写入,当最后写入的一条消息过期时,表示CommitLog文件过期。满足如下任意一个条件,CommitLog文件将会被清理: 每天凌晨4点会清理过期的文件,部分老实例由于未设置时区,清理时间为每天中午12点。 当磁盘使用率达到70%时,会立刻清理过期的文件。 当磁盘使用率达到85%时,会从最早创建的文件开始清理,不管文件是否已过期,直到磁盘空间充足。
  • 查询消息轨迹 在待查询消息所在行,单击“消息轨迹”。 查看消息的轨迹,确定是否生产/消费成功。 消息轨迹的参数说明如表1所示。 表1 消息轨迹的参数说明 参数 参数说明 生产者状态 生产者状态如下: 发送成功:消息发送成功,服务端已经成功存储消息。 提交成功:允许消费者消费此事务消息。 回滚:事务消息将被丢弃,不允许消费者消费此事务消息。 未知,待确认:事务消息状态暂时无法确定,等待固定时间后,服务端向生产者进行消息回查。 生产耗时 生产者发送消息的耗时。 生产地址 生产者的IP地址和端口号。 消费者状态 消费者状态如下: 消费成功 消费超时 消费异常 消费返回NULL 消费失败 消费时间 消费消息的时间。 消费耗时 消费者消费消息的耗时。 消费地址 消费者的IP地址和端口号。
  • 响应示例 状态码: 200 OK { "count" : 1, "events" : [ { "event_id" : 11111, "event_source_type" : "RSU", "event_source_id" : 2, "esn" : "2102312ETX10K7000037", "area_code" : 568, "event_class" : "AbnormalTraffic", "event_type" : 100, "cross_id" : 1111, "event_description" : "交通事故", "event_level" : 1, "event_params" : { "speed" : "60" }, "event_position" : { "lat" : 40.1234567, "lon" : 116.1234567, "ele" : 1000 }, "event_position_name" : "深圳深南大道", "reference_paths" : [ { "active_path" : [ { "lat" : 40.1234567, "lon" : 116.1234567, "ele" : 1000 } ], "path_radius" : 100 } ], "note" : "交通事件信息", "event_status" : "Invalid", "event_confidence" : 1, "event_ex_info" : { "participants" : [ { "ptc_type" : "unknown", "plate_no" : "粤B12345", "speed" : 3000, "vehicle_class" : 54, "gat_vehicle_class" : "k33", "track_id" : 123456789, "lane_no" : 1, "target_rects" : [ { "camera_code" : "abcd", "camera_ip" : "127.0.0.1", "target_pos" : [ { "left_top_x" : 10, "left_top_y" : 10, "right_bottom_x" : 5, "right_bottom_y" : 5 } ], "time_stamp_diff" : 1664507548437 } ], "start_time" : 1664507548437 } ], "congestion_info" : { "level" : 0, "length" : 200, "start_point" : { "lat" : 40.1234567, "lon" : 116.1234567, "ele" : 1000 }, "end_point" : { "lat" : 40.1234567, "lon" : 116.1234567, "ele" : 1000 }, "speed" : 10, "start_time" : 1664507548437, "congestion_lanes_info" : [ { "laneid" : 1, "level" : 0, "length" : 200, "speed" : 10, "start_time" : 1664507548437, "start_point" : { "lat" : 40.1234567, "lon" : 116.1234567, "ele" : 1000 }, "end_point" : { "lat" : 40.1234567, "lon" : 116.1234567, "ele" : 1000 } } ] }, "data_source" : { "radar" : [ 0 ], "camera" : [ 1 ] }, "camera_list" : [ { "id" : 0, "ip" : "127.0.0.1" } ] }, "rsu_id" : [ "b58efc27-a6e5-4bca-9d12-c76ecfe3f102" ], "start_time" : "2019-08-28T16:32:24Z", "end_time" : "2019-08-28T16:32:24Z" } ] }
  • 请求示例 GET https://{endpoint}/v1/{project_id}/history-traffic-events?limit={limit}&offset={offset}&from_date={from_date}&to_date={to_date}&event_class={event_class}&event_type={event_type}&event_source={event_source}&event_id={event_id} Content-Type:application/json X-Auth-Token:******** Instance-Id:********
  • 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型 描述 subscription_type String 订阅类型字段 枚举值: DEVICE_ALARM 智能告警消息(含第三方告警),该消息的数据推送结构体设备智能告警消息结构体 DEVICE_EXCEPTION 设备异常消息,该消息的数据推送结构体设备异常告警消息结构体 DEVICE_UNBIND 设备解绑、套餐解绑数据,该消息的数据推送结构体设备解绑消息结构体 TARGET_DATA 目标TLV数据,该消息的数据推送结构体目标数据消息结构体 THIRD_DATA 第三方TLV数据,该消息的数据推送结构体三方数据消息结构体 VEHICLE_DATA 机非人TLV数据,该消息的数据推送结构体机非人消息结构体 HEAD_SHOULDER_DATA 头肩业务TLV数据,该消息的数据推送结构体头肩业务消息结构体 BEHAVIOR_ANALYSIS_DATA 行为分析TLV数据,该消息的数据推送结构体行为分析与人车物分离消息结构体 MICRO_CHECKPOINT_DATA 微卡口TLV数据,该消息的数据推送结构体微卡口数据推送结构体
  • URI DELETE /v1/{user_id}/messages/callback 表1 路径参数 参数 是否必选 参数类型 描述 user_id 是 String 用户ID:由数字组成,长度范围[15,25],获取方式参考获取user ID与下载AK/SK章节 表2 Query参数 参数 是否必选 参数类型 描述 subscription_type 是 String 订阅类型字段 枚举值: DEVICE_ALARM 智能告警消息(含第三方告警),该消息的数据推送结构体设备智能告警消息结构体 DEVICE_EXCEPTION 设备异常消息,该消息的数据推送结构体设备异常告警消息结构体 DEVICE_UNBIND 设备解绑、套餐解绑数据,该消息的数据推送结构体设备解绑消息结构体 TARGET_DATA 目标TLV数据,该消息的数据推送结构体目标数据消息结构体 THIRD_DATA 第三方TLV数据,该消息的数据推送结构体三方数据消息结构体 VEHICLE_DATA 机非人TLV数据,该消息的数据推送结构体机非人消息结构体 HEAD_SHOULDER_DATA 头肩业务TLV数据,该消息的数据推送结构体头肩业务消息结构体 BEHAVIOR_ANALYSIS_DATA 行为分析TLV数据,该消息的数据推送结构体行为分析与人车物分离消息结构体 MICRO_CHECKPOINT_DATA 微卡口TLV数据,该消息的数据推送结构体微卡口数据推送结构体
  • 响应参数 状态码: 200 表4 响应Body参数 参数 参数类型 描述 messages Array of messages objects 消息列表。 total Number 消息总数。 size Number 返回总条数。 表5 messages 参数 参数类型 描述 topic String topic名称。 partition Integer 消息所在的分区。 key String 消息key。 value String 消息内容。 size Integer 消息大小。 timestamp Integer topic名称。 huge_message Boolean 大数据标识。 message_offset Integer 消息偏移量。 message_id String 消息ID。 app_id String 集成应用key。 tag String 消息标签。 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String 错误信息 状态码: 403 表7 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String 错误信息