• 依赖拓扑：增强查看某历史时间范围内服务（POD）到服务（POD）全栈路径拓扑以及全景上下游拓扑。
• 调用链追踪：增强查看某个应用 Span 对应系统 Span、网络 Span 时延消耗以及追踪未插码服务的能力。

01

全栈路径拓扑-界面

• 客户端时延：④=204.31ms，为请求服务端的总时延，由以下几部分组成
• 客户端容器网络：路径①（也就是⑤-④），图中所示为38.14us
• 云网络：路径②（也就是⑥-⑤），图中所示为273.13us
• 服务端容器网络：路径③（也就是⑦-⑥），图中所示为204.25ms
• 服务端：即图中⑦，为372.83us

02

全栈路径拓扑-API

SELECT Avg(`request`), /* 需要查看的指标量 */ 
       pod_service_0,  /* 客户端服务名称，客户端为 POD，则替换为 pod_0 */
       tap_side, 
       pod_service_1 /* 服务端服务名称，服务端为 POD，则替换为 pod_1 */
FROM vtap_app_edge_port  /* 查看应用指标使用 vtap_app_edge_port；查看网络指标切换到 vtap_flow_edge_port */
WHERE time>=1678760220 AND time<=1678762020 AND 
      pod_service_0='deepflow-server' AND  /* 过滤客户端 */
      pod_service_1='deepflow-server'   /* 过滤服务端 */
GROUP BY pod_service_0, 
         tap_side, 
         pod_service_1,

03

全景上下游拓扑-界面

04

全景上下游拓扑-API

SELECT Avg(`request`), /* 需要查看的指标量 */ 
       pod_service_0,  /* 客户端服务名称，客户端为 POD，则替换为 pod_0 */
       tap_side, 
       pod_service_1 /* 服务端服务名称，服务端为 POD，则替换为 pod_1 */
FROM vtap_app_edge_port  /* 查看应用指标使用 vtap_app_edge_port；查看网络指标切换到 vtap_flow_edge_port */
WHERE time>=1678760220 AND time<=1678762020 AND 
      pod_service_1='deepflow-server'   /* 需要查看上游数据的服务 */
GROUP BY pod_service_0, 
         tap_side, 
         pod_service_1,

获取下游数据

SELECT Avg(`request`), /* 需要查看的指标量 */ 
       pod_service_0,  /* 客户端服务名称，客户端为 POD，则替换为 pod_0 */
       tap_side, 
       pod_service_1 /* 服务端服务名称，服务端为 POD，则替换为 pod_1 */
FROM vtap_app_edge_port  /* 查看应用指标使用 vtap_app_edge_port；查看网络指标切换到 vtap_flow_edge_port */
WHERE time>=1678760220 AND time<=1678762020 AND 
      pod_service_0='deepflow-server'   /* 需要查看下游数据的服务 */
GROUP BY pod_service_0, 
         tap_side, 
         pod_service_1,

05

调用链追踪-产品

• 图中 A 表示应用 Span（来源传统 APM）；S 表示网络 Span（来源 DeepFlow）；N 表示网络 Span（来源 DeepFlow）

• 图中黑色部分为发起全栈调用追踪的的应用 Span，后续统称为 应用 Span Y

• 图中蓝色部分为通过 应用 Span Y 追踪的路径中的系统和网络 Span

• 图中绿色部分为通过 应用 Span Y 追踪的下游未插码的 Span

• 图中红色部分为通过 应用 Span Y 追踪的上游未插码的 Span

06

调用链追踪-API

SELECT response_duration,
       start_time,
       end_time,
       resource_gl0_0, /* 客户端 */
       resource_gl0_1, /* 服务端 */
       tap_port_type,  /* eBPF、NIC ... */
       tap_port,       /* NIC Name */
       trace_id,
       span_id
FROM l7_flow_log
WHERE trace_id = 'c5ad367da7ed41fc97921d91a0584bd8.63.16620935428909473' AND
      span_id = 'e05ee7a06d674085a16dfea36ed11b98.169.16620935428971714-2' AND /* 非必须，精确搜索 */
      time >= 1662093572 AND time <= 1662095372 /* 加速搜索 */

• ① 根据应用 Span Y 的 TraceID + SpanID 追踪 DeepFlow 的系统 Span，此时可能会得到多个系统 Span，只需要获取与应用 Span Y紧邻的系统 Span X继续往下追踪即可（可通过总时延最长来判断）
• ② 获取系统 Span X的 syscall_trace_id_request 作为其他系统 Span 的搜索条件，得到系统 Span Z

SELECT response_duration,  /* SELECT 字段可以根据需求自定义即可*/
       l7_protocol,
       Enum(request_type),
       request_resource,
       process_kname_0,
       process_kname_1,
       tap_side,
       req_tcp_seq, 
       resp_tcp_seq,
       Enum(auto_instance_type_0) AS `client_Enum(auto_instance_type_0)`,
       auto_instance_0,  
       Enum(auto_instance_type_1) AS `server_Enum(auto_instance_type_1)`, 
       auto_instance_1, 
FROM l7_flow_log  
WHERE time>=1678764261 AND /*追踪开始时间，建议设置比系统 Span X 的开始时间早 3min*/
      time<=1678767861 AND /*追踪结束时间，建议设置比系统 Span X 的结束时间晚 3min*//
      (syscall_trace_id_request=16787489195430278) /* 16787489195430278 为 系统 Span Y 的 syscall_trace_id_request */
ORDER BY `end_time` 

• ③ 获取系统 Span Z 的 req_tcp_seq/resp_tcp_seq 作为其他系统 Span 和网络 Span 的搜索条件，得到网络 Span Z.1/Z.2 以及系统 Span Q，此处逻辑特别注意：req_tcp_seq !=0 & resp_tcp_seq !=0 则需要同时满足 req_tcp_seq 和 resp_tcp_seq；如果其中一个为 0，则任意满足一个即可

SELECT response_duration,  /* SELECT 字段可以根据需求自定义即可*/
       l7_protocol,
       Enum(request_type),
       request_resource,
       process_kname_0,
       process_kname_1,
       tap_side,
       req_tcp_seq, 
       resp_tcp_seq,
       Enum(auto_instance_type_0) AS `client_Enum(auto_instance_type_0)`,
       auto_instance_0,  
       Enum(auto_instance_type_1) AS `server_Enum(auto_instance_type_1)`, 
       auto_instance_1, 
FROM l7_flow_log  
WHERE time>=1678764261 AND 
      time<=1678767861 AND 
      (type=2 AND 
      req_tcp_seq=3575241005 AND /* 3575241005 为系统 Span Z 的 req_tcp_seq*/
      resp_tcp_seq=995863176) /* 995863176 为系统 Span Z 的 resp_tcp_seq*/
ORDER BY `end_time` 

• ④ 接下来可继续追踪系统 Span Q 的上游系统 Span，这里将分两种情况，如果上游的系统 Span 与系统 Span Q 在同一个线程，则重复步骤 [2]/[3] 即可，如果在不同线程/进程中，目前仅支持网关设置了 X-Request-ID 的情况下继续追踪，获取系统 Span Q的 x-request-id 作为查询其他系统 Span 和网络 Span 的搜索条件，得到其上游的系统 Span M

SELECT response_duration,  /* SELECT 字段可以根据需求自定义即可*/
       l7_protocol,
       Enum(request_type),
       request_resource,
       process_kname_0,
       process_kname_1,
       tap_side,
       req_tcp_seq, 
       resp_tcp_seq,
       Enum(auto_instance_type_0) AS `client_Enum(auto_instance_type_0)`,
       auto_instance_0,  
       Enum(auto_instance_type_1) AS `server_Enum(auto_instance_type_1)`, 
       auto_instance_1, 
FROM l7_flow_log  
WHERE time>=1678764261 AND 
      time<=1678767861 AND 
      x_request_id=6e903947-5ef0-4c63-91a8-a2a599171633 /* 6e903947-5ef0-4c63-91a8-a2a599171633 为系统 Span Q 的 x_request_id*/
ORDER BY `end_time` 

• ⑤ 到此，已经根据上述步骤追踪得到所有的上游 Span，接下来将确定父子关系，可直接根据总的响应时延，按从大到小降序排列即可

07

什么是 DeepFlow

参考资料