@@ -70,6 +70,15 @@ def __init__(self, **kwargs):
7070 self .__dict__ [key ] = val
7171
7272 def attach (self ):
73+ config .init (
74+ collector_address = self .probe_config ["skywalking" ]["collector" ]["backend_service" ],
75+ service_name = self .probe_config ["skywalking" ]["agent" ]["service_name" ],
76+ log_reporter_active = True ,
77+ force_tls = self .probe_config ["spp" ]["disable_tls" ] is False ,
78+ log_reporter_formatted = False
79+ )
80+ agent .start ()
81+
7382 ca_data = None
7483 if self .probe_config ["spp" ]["disable_tls" ] is False \
7584 and self .probe_config ["spp" ].get ("probe_certificate" ) is not None :
@@ -88,20 +97,13 @@ def attach(self):
8897 self .__send_connected (eb )
8998 self .instrument_remote = LiveInstrumentRemote (eb )
9099
91- config .init (
92- collector_address = self .probe_config ["skywalking" ]["collector" ]["backend_service" ],
93- service_name = self .probe_config ["skywalking" ]["agent" ]["service_name" ],
94- log_reporter_active = True ,
95- force_tls = self .probe_config ["spp" ]["disable_tls" ] is False ,
96- log_reporter_formatted = False
97- )
98- agent .start ()
99-
100100 def __send_connected (self , eb : EventBus ):
101101 probe_metadata = {
102102 "language" : "python" ,
103103 "probe_version" : __version__ ,
104- "python_version" : sys .version
104+ "python_version" : sys .version ,
105+ "service" : config .service_name ,
106+ "service_instance" : config .service_instance
105107 }
106108
107109 # add hardcoded probe meta data (if present)
0 commit comments