使用以下包装类实现traceId链路传递

• CallableWrapper
• RunnableWrapper
• SupplierWrapper

使用方法

    ExecutorService executorService = Executors.newFixedThreadPool(1);
    executorService.submit(CallableWrapper.of(new Callable<String>() {
        @Override public String call() throws Exception {
            return null;
        }
    }));

    ExecutorService executorService = Executors.newFixedThreadPool(1);
    executorService.execute(RunnableWrapper.of(new Runnable() {
        @Override public void run() {
            //your code
        }
    }));

    CompletableFuture.supplyAsync(SupplierWrapper.of(()->{
            return "SupplierWrapper";
    }));

链路追踪方法，携带参数，返回值

@Trace
@Tags({@Tag(key = "参数", value = "arg[0]"), @Tag(key = "返回值", value = "returnedObj")})
public Object method(Object param){

}

对象要重写toString()方法，不然，展示的是对象的地址

pip install apache-skywalking

from skywalking import agent,config 
config.init(agent_collector_backend_services='${skywalking-oap地址}', agent_name='${项目名称}')
agent.start()

from skywalking import agent,config 
config.init(agent_collector_backend_services='49.4.88.64:11800', agent_name='skywalking-test-python')
agent.start()

pip install skywalking_trace==1.1.4

from skywalking_trace.trace_log import  TraceLog

log = TraceLog()
log.info("xxxxxx")