File tree Expand file tree Collapse file tree 2 files changed +3
-54
lines changed
exporters/aws-otel-otlp-udp-exporter/validation-app Expand file tree Collapse file tree 2 files changed +3
-54
lines changed Original file line number Diff line number Diff line change 5858 echo "Waiting for X-Ray daemon to start..."
5959 sleep 5
6060
61- # Check if process is still running
62- if ps -p $XRAY_PID > /dev/null; then
63- echo "✅ X-Ray daemon process is running"
64- else
65- echo "❌ X-Ray daemon process is not running"
66- echo "Log contents:"
67- cat daemon-logs/xray-daemon.log
68- exit 1
69- fi
70-
71- # Try to connect to the daemon
72- if nc -zv 127.0.0.1 2000 2>&1; then
73- echo "✅ Successfully connected to X-Ray daemon on port 2000"
74- else
75- echo "❌ Cannot connect to X-Ray daemon on port 2000"
76- echo "Log contents:"
77- cat daemon-logs/xray-daemon.log
78- exit 1
79- fi
80-
81- # Extra verification with curl (might not work depending on daemon setup)
82- if curl -s http://localhost:2000/GetDaemonVersion; then
83- echo "✅ X-Ray daemon API responded"
84- else
85- echo "ℹ️ X-Ray daemon doesn't support API or not ready yet"
86- # Don't exit with error as this might not be reliable
87- fi
88-
8961 echo "X-Ray daemon setup completed"
9062
9163 - name : Setup validation app
11284 echo "❌ No evidence of traces being received by X-Ray daemon"
11385 exit 1
11486 fi
87+
88+ # TODO: Steps to publish to PyPI
Original file line number Diff line number Diff line change 88from opentelemetry .sdk .trace .export import BatchSpanProcessor
99
1010
11- # Set up a UDP server to verify data is sent
12- def udp_server ():
13- sock = socket .socket (socket .AF_INET , socket .SOCK_DGRAM )
14- sock .bind (("127.0.0.1" , 2000 ))
15- sock .settimeout (5 )
16- print ("UDP server listening on 127.0.0.1:2000" )
17- try :
18- data , addr = sock .recvfrom (4096 )
19- print (f"Received data from { addr } " )
20- if data :
21- print ("✅ Successfully received exported span data" )
22- return True
23- except socket .timeout :
24- print ("❌ No data received within timeout period" )
25- return False
26- finally :
27- sock .close ()
28-
29-
30- # Start UDP server in a separate thread
31- server_thread = threading .Thread (target = udp_server )
32- server_thread .daemon = True
33- server_thread .start ()
34-
3511# Set up tracer provider
3612tracer_provider = TracerProvider ()
3713trace .set_tracer_provider (tracer_provider )
3814
39- # Set up UDP exporter with batch processor (more realistic usage)
15+ # Set up UDP exporter with batch processor
4016exporter = OTLPUdpSpanExporter (endpoint = "127.0.0.1:2000" )
4117span_processor = BatchSpanProcessor (exporter )
4218tracer_provider .add_span_processor (span_processor )
@@ -62,4 +38,3 @@ def udp_server():
6238
6339# Shutdown
6440tracer_provider .shutdown ()
65- print ("Test completed" )
You can’t perform that action at this time.
0 commit comments