Подключение к удаленному Jaegertracing с C#. Net Core - PullRequest
Новая
       107

Подключение к удаленному Jaegertracing с C#. Net Core

0 голосов
/ 12 июля 2020

У меня тут проблемы с Opentracing и Jaegertracing, когда дело доходит до C#. У меня это работало раньше, но с проектами Java. Поэтому я начинаю задаваться вопросом, чего мне не хватает, когда дело доходит до C#. NET Core веб-службы.

Это мой класс для запуска моего трассировщика, который будет использоваться 

    public static class MyTracer
    {
        public static ITracer tracer = null;

        public static ITracer InitTracer()
        {
            Environment.SetEnvironmentVariable("JAEGER_SERVICE_NAME", "my-store");
            Environment.SetEnvironmentVariable("JAEGER_AGENT_HOST", "192.168.2.27");
            Environment.SetEnvironmentVariable("JAEGER_AGENT_PORT", "6831");
            Environment.SetEnvironmentVariable("JAEGER_SAMPLER_TYPE", "const");                     
            Environment.SetEnvironmentVariable("JAEGER_REPORTER_LOG_SPANS", "false");
            Environment.SetEnvironmentVariable("JAEGER_SAMPLER_PARAM","1");
            Environment.SetEnvironmentVariable("JAEGER_SAMPLER_MANAGER_HOST_PORT", "5778");
            Environment.SetEnvironmentVariable("JAEGER_REPORTER_FLUSH_INTERVAL" , "1000");
            Environment.SetEnvironmentVariable("JAEGER_REPORTER_MAX_QUEUE_SIZE" , "100");


            var loggerFactory = new LoggerFactory();

            var config = Configuration.FromEnv(loggerFactory);

            tracer = config.GetTracer();

            if (!GlobalTracer.IsRegistered())
            {
                GlobalTracer.Register(tracer);
            }
            return tracer;
        }
    }

Контроллер код, который должен сообщать агенту Jaeger и сборщику для отображения в пользовательском интерфейсе. 

[Route("api/[controller]")]
[ApiController]
public class ComponentController : ControllerBase
{
    private readonly ITracer tracer;

    public ComponentController(ITracer tracer)
    {
        this.tracer = tracer;
    }

    /// <summary>
    /// Get component by ID
    /// </summary>
    /// <returns></returns>
    [HttpGet("GetComponent")]
    public ActionResult<ComponentModel> GetComponent(string id)
    {   
        var builder = tracer.BuildSpan("operationName");            
        var span = builder.Start();
        // Set some context data
        span.Log("Getting data");
        span.SetTag(Tags.SpanKind, "Getting data request");
        span.Finish();                     

        ComponentModel component = ComponentManager.GetComponent(id);    

        return component;
    }


}

Startup.cs 

    public class Startup
{
    public Startup(IConfiguration configuration)
    {
        Configuration = configuration;
    }

    public IConfiguration Configuration { get; }

    // This method gets called by the runtime. Use this method to add services to the container.
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddControllers();

        // Use "OpenTracing.Contrib.NetCore" to automatically generate spans for ASP.NET Core, Entity Framework Core, ...
        // See https://github.com/opentracing-contrib/csharp-netcore for details.
        services.AddOpenTracing();

        //Init tracer
        services.AddSingleton<ITracer>(t => MyTracer.InitTracer());

        services.AddHealthChecks();
    }

    // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
    public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
    {
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }
        app.UseHttpsRedirection();
        app.UseRouting();
        app.UseAuthorization();
        app.UseEndpoints(endpoints =>
        {
            endpoints.MapControllers();
        });
    }
}

Но это вообще не работает. Что мне здесь не хватает для работы с удаленным сервером?

1 Ответ

1 голос
/ 12 июля 2020

IV наконец нашел решение. Похоже, это связано с тем, как репортер заводится. Как бы то ни было, я изменил свой класс трассировки на этот. 

    public static class MyTracer
{
    public static ITracer tracer = null;
    public static ITracer InitTracer(IServiceProvider serviceProvider)
    {
        string serviceName = serviceProvider.GetRequiredService<IHostingEnvironment>().ApplicationName;

        Environment.SetEnvironmentVariable("JAEGER_SERVICE_NAME", "my-store");
        //Environment.SetEnvironmentVariable("JAEGER_AGENT_HOST", "192.168.2.27");
        //Environment.SetEnvironmentVariable("JAEGER_AGENT_PORT", "6831");
        //Environment.SetEnvironmentVariable("JAEGER_SAMPLER_TYPE", "const");                     
        //Environment.SetEnvironmentVariable("JAEGER_REPORTER_LOG_SPANS", "false");
        //Environment.SetEnvironmentVariable("JAEGER_SAMPLER_PARAM","1");
        //Environment.SetEnvironmentVariable("JAEGER_SAMPLER_MANAGER_HOST_PORT", "5778");
        //Environment.SetEnvironmentVariable("JAEGER_REPORTER_FLUSH_INTERVAL" , "1000");
        //Environment.SetEnvironmentVariable("JAEGER_REPORTER_MAX_QUEUE_SIZE" , "100");
        //application - server - id = server - x

        var loggerFactory = serviceProvider.GetRequiredService<ILoggerFactory>();

        var sampler = new ConstSampler(sample: true);
        var reporter = new RemoteReporter.Builder()
         .WithLoggerFactory(loggerFactory)
         .WithSender(new UdpSender("192.168.2.27", 6831, 0))
         .Build();

        tracer = new Tracer.Builder(serviceName)
         .WithLoggerFactory(loggerFactory)
         .WithSampler(sampler)
         .WithReporter(reporter)
         .Build();

        if (!GlobalTracer.IsRegistered())
        {
            GlobalTracer.Register(tracer);
        }
        return tracer;
    }
}

Я знаю, что прямо сейчас здесь есть несколько неактивных переменных. Посмотрим, могут ли они еще как-нибудь пригодиться. Но сейчас ничего не нужно, чтобы начать работу. Надеюсь, это поможет кому-то еще, пытаясь заставить ядро. NET правильно работать вместе с удаленным сервером Jeagertracing.

...