|
| 1 | +<?php |
| 2 | + |
| 3 | +declare(strict_types=1); |
| 4 | + |
| 5 | +use GuzzleHttp\Psr7\Request; |
| 6 | +use Http\Adapter\Guzzle7\Client; |
| 7 | +use Monolog\Handler\StreamHandler; |
| 8 | +use Monolog\Logger; |
| 9 | +use OpenTelemetry\API\Common\Instrumentation; |
| 10 | +use OpenTelemetry\API\Trace\Propagation\TraceContextPropagator; |
| 11 | +use OpenTelemetry\SDK\Common\Export\Stream\StreamTransport; |
| 12 | +use OpenTelemetry\SDK\Common\Log\LoggerHolder; |
| 13 | +use OpenTelemetry\SDK\Common\Time\ClockFactory; |
| 14 | +use OpenTelemetry\SDK\Resource\ResourceInfoFactory; |
| 15 | +use OpenTelemetry\SDK\Trace\Sampler\AlwaysOnSampler; |
| 16 | +use OpenTelemetry\SDK\Trace\SpanExporter\ConsoleSpanExporter; |
| 17 | +use OpenTelemetry\SDK\Trace\SpanProcessor\BatchSpanProcessor; |
| 18 | +use OpenTelemetry\SDK\Trace\TracerProvider; |
| 19 | +use Psr\Log\LogLevel; |
| 20 | + |
| 21 | +require_once dirname(__DIR__) . '/vendor/autoload.php'; |
| 22 | + |
| 23 | +LoggerHolder::set( |
| 24 | + new Logger('otel-php', [new StreamHandler(STDOUT, LogLevel::DEBUG)]) |
| 25 | +); |
| 26 | + |
| 27 | +$transport = new StreamTransport(fopen('php://stdout', 'a'), 'application/json'); |
| 28 | +$exporter = new ConsoleSpanExporter($transport); |
| 29 | + |
| 30 | +$tracerProvider = new TracerProvider( |
| 31 | + new BatchSpanProcessor($exporter, ClockFactory::getDefault()), |
| 32 | + new AlwaysOnSampler(), |
| 33 | + ResourceInfoFactory::emptyResource(), |
| 34 | +); |
| 35 | + |
| 36 | +$scope = Instrumentation\Configurator::create() |
| 37 | + ->withTracerProvider($tracerProvider) |
| 38 | + ->withPropagator(TraceContextPropagator::getInstance()) |
| 39 | + ->activate(); |
| 40 | + |
| 41 | +$root = $tracerProvider->getTracer('async-requests-demo')->spanBuilder('root')->startSpan(); |
| 42 | +$rootScope = $root->activate(); |
| 43 | + |
| 44 | +try { |
| 45 | + $requests = [ |
| 46 | + new Request('GET', 'https://postman-echo.com/get'), |
| 47 | + new Request('POST', 'https://postman-echo.com/post'), |
| 48 | + new Request('GET', 'https://httpbin.org/does-not-exist'), |
| 49 | + new Request('GET', 'https://httpbin.org/get'), |
| 50 | + ]; |
| 51 | + $client = new Client(); |
| 52 | + $promises = []; |
| 53 | + foreach ($requests as $request) { |
| 54 | + $promises[] = [$request, $client->sendAsyncRequest($request)]; |
| 55 | + } |
| 56 | + foreach ($promises as [$request, $promise]) { |
| 57 | + try { |
| 58 | + $response = $promise->wait(); |
| 59 | + echo sprintf('[%d] ', $response->getStatusCode()) . json_encode(json_decode($response->getBody()->getContents()), JSON_PRETTY_PRINT), PHP_EOL; |
| 60 | + } catch (\Exception $e) { |
| 61 | + var_dump($e->getMessage()); |
| 62 | + } |
| 63 | + } |
| 64 | + |
| 65 | + $root->end(); |
| 66 | +} finally { |
| 67 | + $rootScope->detach(); |
| 68 | + $scope->detach(); |
| 69 | + $tracerProvider->shutdown(); |
| 70 | +} |
0 commit comments