Asynchrone Anfrage an Amazon Firehose

Question

Ist es möglich, Anfragen asynchron an AWS zu senden? In der wirklichen Bedeutung.

Die Nachrichten wird nicht geliefert, wenn ich versuche, sie in einer Weise zu senden:

 $firehose = new FirehoseClient($args); 
     /** @var Promise\Promise $promise */ 
     $promise = $firehose->putRecordAsync($record); 
     $promise->then(function ($result) { 
      echo 'test'; 
     }); 

aber wenn ich am Ende des Skripts hinzu:

$promise->wait() 

es funktioniert, aber synchron. Gibt es eine Möglichkeit, es asynchron zu machen?

Ich habe auch versucht, einen anderen Handler zu verwenden:

$curl = new CurlMultiHandler(); 
    $handler = HandlerStack::create($curl); 
    $args = [ 
     'http_handler' => $handler, 
     'region' => '#REGION#', 
     'version' => 'latest', 
     'credentials' => $credentials, 
     'debug' => true 
    ]; 
    $firehose = new FirehoseClient($args); 

    while (!Promise\is_settled($promise)) { 
     $curl->tick(); 
    } 

Im Grunde funktioniert es, aber immer im Sync-Modus. Was ich brauche, ist eine Anfrage an AWS zu senden und nicht auf die Antwort zu warten.

Answer 1

Die beste Lösung für Ihr Problem ist die Verwendung einer Event-Loop-Implementierung, wie zum Beispiel ReactPHP.

Leider ist Guzzle (besser gesagt, cURL selbst) nicht kompatibel, um in einer Event-Schleife sofort zu funktionieren.

Persönlich habe ich ein gleiches Problem durch die Implementierung eines bridge gelöst, um Guzzle-Abfragen Event-Loop-freundlich zu laufen. Bitte werfen Sie einen Blick auf the examples.

So könnte der Code wie folgt aussehen:

run(function ($loop) use ($genFn) { 
    $httpHandler = new CurlMultiHandler($loop); 
    $stack = HandlerStack::create($httpHandler); 

    $httpClient = new Client([ 
     'handler' => $stack, 
    ]); 

    $promise = $httpClient->getAsync('https://google.com')->then(
     function ($result) { echo 'Query completed!'; }, 
     function ($reason) { echo 'Query failed.'; } 
    ); 

    /* 
    * The promise isn't completed yet, but the event loop will take care of it. 
    * We don't need to call Promise::wait()! 
    */ 
}); 

Answer 2

Ich habe nicht mit Async-Code in PHP gearbeitet, aber ich habe solche Dinge in Python.

Aus allgemeiner Sicht können Sie keine Vorteile einer einzelnen Async-Anfrage erhalten, die vom Synchronisierungscode umgeben ist. Sie sollten in einer vollständig asynchronen Umgebung arbeiten (d. H. Sie benötigen eine Art äußere Ereignisschleife). ReactPHP scheint einer von denen zu sein.

Sie können auch davon profitieren, mehrere API-Anfragen gleichzeitig zu machen und auf alle zusammen zu warten. Wie in diesem Beispiel http://docs.aws.amazon.com/aws-sdk-php/v3/guide/guide/promises.html#executing-commands-concurrently Es wird schneller arbeiten als mehrere Synchronisierungsaufrufe hintereinander.

Ich hoffe es hilft.