2017-10-19 28 views
0

は私のPythonコードは、今だ:PythonでSQSメッセージを非同期で送信する方法は?ここ

sqs = boto3.resource('sqs') 
queue = sqs.get_queue_by_name(Queue='test') 
msg = 'hello world' 
for i in range(0,1000): 
    queue.send_message(MessageBody = msg) 
    print("Message Sent") 

そしてここでは、Node.jsのバージョンです:

var sqs = new AWS.SQS({apiVersion: '2012-11-05'}); 
var params = { 
    MessageBody: 'hello world', 
    QueueUrl: // Queue URL here 
}; 
for(var i = 0; i < 1000; i++){ 
    sqs.sendMessage(params, function(err,data){ 
     if(err){ 
      throw err; 
     } else { 
      console.log("Message Sent"); 
     } 
    }) 
} 

私の問題は、それはそれので、Pythonスクリプトを使用して1000件のメッセージを送信するために非常に長い時間がかかるということです非同期的にNode.jsに対して同期的に実行されます。私はどこからでも見てきました。私はPythonでメッセージを非同期に送信する方法を見つけることができません。インサイトは大変感謝しています。

答えて

0

boto3ライブラリは非同期呼び出しをサポートしていません。 aiobotocoreと呼ばれるSQSのテストでS3をサポートするライブラリがあります。これらのリンクは、より多くの情報を持っている:

aiobotocore

Support asyncio

+0

ありがとうございました。私はこれらを調べます。 – Matt

関連する問題