日志查询

同一时间只能查询一个Topic的消息。若需要更强大的查询，请参考DWS中查看。

1. 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。
2. 在左侧的导航栏选择“消息集成 MQS > 消息查询”，进入消息查询页面。
3. 在页面右上角选择要查询消息的Topic，界面自动展示该Topic中存储的消息记录。
   图1 查询消息
   

   默认按消息生产时间查询最近 10 分钟内生产的消息。若要查询更大时间范围内的消息或按其它方式查询请使用高级搜索功能。若查询超时，请在高级搜索中适当调小查询时间范围。

   图2 高级搜索
   

   另外高级搜索也支持按偏移量查询。

   图3 按偏移量查询
   

   表1 消息内容说明

   参数	说明
   Topic名称	消息所在的Topic名称。
   消息ID	每条消息的标识，用户通过生产消息的消息头中message_id的值确定。
   应用Key	每条消息的应用Key，用户通过生产消息的消息头中TAGS的值确定。
   分区	消息所在的分区，编号从0开始。查询方式为“按偏移量查询”时必填。
   偏移量	消息在分区中的偏移量。
   业务Key	消息中携带的业务Key，用于标识消息发送所属的业务。
   标签	客户端向Topic生产消息时所携带的标签，一般业务场景下不使用标签。
   消息大小(B)	消息的大小。
   生产时间	消息生产的时间。

4. 单击消息记录上的“消息内容”，在消息详情弹窗中可查看消息的具体内容。
   图4 消息详情
   

1. 参考使用Data Studio连接DWS链接DWS。
2. 在SQL终端中使用SQL查询日志信息。
   【示例】全表查询

   select 
    *  
   from 
    apilog.log_kafka;

   图5 全表查询
   

   查询指定参数并按照访问的start_time排序

   select 
    start_time,batch_id,api_id,app_id,upstream_status,upstream_response_time,request_id,response_body,response_header  
   from 
    apilog.log_kafka  
   order by 
    start_time  
   DESC;

   查询指定集成应用的总访问量

   select 
   count(*)  
   from 
    apilog.log_kafka  
   where 
    provider_app_id= 
   'fcec3c73-cfe0-418c-b775-42d084199510' 
   ;

   

   请根据实际需求使用SQL语法