Amazon Firehoseへの非同期リクエスト

Question

AWSに非同期でリクエストを送信することはできますか？本当の意味で。私は方法でそれを送信しようとしている場合

メッセージが配信されていません。

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

が、私は、スクリプトの最後に追加したとき：それが動作

$promise->wait() 

が、同期的に。非同期にする方法はありますか？しかし、常に同期モードでは、

$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(); 
    } 

は基本的にそれが動作：

は、私はまた、別のハンドラを使用することを試みました。私が必要とするのは、AWSにリクエストを送信し、その答えを待つことではありません。

Answer 1

問題の最適な解決策は、たとえばReactPHPのようなイベントループの実装を使用することです。

残念ながら、Guzzle（よく言えば、cURL自体）は、そのままのイベントループでは動作しません。

私は、イベントループに優しいGuzzleクエリを実行するためにbridgeを実装することで、同等の問題を解決しました。どうぞ、the examplesをご覧ください。

ので、コードは次のようになります。

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

私はPHPで非同期コードで動作しませんでしたが、私はPythonでこのようなことを行いました。

一般的な理解から、シンクコードで囲まれた単一の非同期要求の利点を得ることはできません。完全に非同期の環境で作業する必要があります（つまり、何らかの外部イベントループが必要です）。 ReactPHPはそれらの1つに見えます。

また、複数のAPIリクエストを同時に作成し、すべてのリクエストを一緒に待つことでメリットを得ることができます。この例のようにhttp://docs.aws.amazon.com/aws-sdk-php/v3/guide/guide/promises.html#executing-commands-concurrently複数の同期呼び出しを連続して行うよりも速く動作します。

私はそれが役に立ちそうです。