amazon-sqs

0熱度

2回答

我想使用AWS S3來允許一些用戶將文件添加到S3存儲桶。然後，我想在添加新文件時生成SQS消息。最後，我想要使用SQS消息並使用特定類的後臺作業人員處理它。我想使用SQS消息屬性來確定我應該使用哪個後臺作業工作類進行處理。正如SQS消息屬性文檔所述：消息使用者可以使用消息屬性來幫助決定如何處理消息，而不必先處理消息正文。（通過SQS Developer Guide）但是，在S3存儲的

0熱度

1回答

AWS CLI和Java SDK返回不正確的網址，SQS隊列

我有一個配置文件配置我的AWS CLI工具在我的主目錄與我的區域設置爲eu-west-1並能成功地列出隊列： ➜ ~ aws sqs list-queues { "QueueUrls": [ "https://eu-west-1.queue.amazonaws.com/9*********42/second" ] } 我有下面的方法： void sendMe

0熱度

1回答

如何以編程方式生成Amazon SQS隊列（ASP.Net）以獲取AnyOfferChanged通知？

我們希望創造編程下面的東西要麼通過ASP.Net或通過JSON得到AnyOfferChanged通知創建亞馬遜標準SQS隊列添加權限產生的隊列中。創建SNS主題創建主題訂閱謝謝拉吉

0熱度

1回答

使用java和spring的AWS SQS異步查詢偵聽器。如何將環境變量中的值插入@MessageMapping批註

我在Amazon SQS中有一堆隊列，並且我有一個在彈簧服務中運行的異步隊列偵聽器。我跟着this tutorial，它像一個魅力。我的問題是，我不能將隊列名稱硬編碼到@MessageMapping註釋中，我需要能夠從用戶定義的環境變量中獲取它。這裏有一點我在說... @MessageMapping("queueName") public void onSQSMessage(String pay

0熱度

1回答

如何在python中異步發送SQS消息？

這裏是我的Python代碼現在： 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 S

4熱度

1回答

作爲運行時異常拋出的NoHttpResponseException即使是已檢查的異常

我遇到一個奇怪的問題，其中org.apache.http.NoHttpResponseException作爲未經檢查的異常拋出，即使是已檢查的異常，因爲它延伸java.io.IOException ...從以下內容可以看出發佈stacktrace我收到一個異常，應該在編譯時檢查爲未經檢查的運行時異常。，我得到的是如下異常的堆棧跟蹤（我的課是在包：com.example.staticsite）：

0熱度

1回答

爲什麼AWS SQS如此之慢？

我一直在測試發送消息並從SQS隊列接收消息所花費的時間。它需要平均800-1200毫秒，這似乎是一個荒謬的很長一段時間。這裏是我的測試代碼，請告訴我，如果我做錯了什麼。 var t0; sendMessage('hello'); function sendMessage(message){ var params = { MessageBody: message,

0熱度

1回答

如何修改Spring Cloud AWS用於反序列化SQS消息的對象映射器？

我需要修改Spring Cloud AWS在反序列化JSON並使用它註冊JavaTime模塊時使用的Jackson2對象映射器。這是因爲SQS有效載荷包含必須使用JavaTime模塊進行反序列化的Java Instant類實例。細節：這是SQS監聽方法： @SqsListener(value = "mysqs",deletionPolicy = SqsMessageDeletionPolicy

1熱度

1回答

如何使用彈簧集成加速sqs隊列的消耗

我正在嘗試設置一個集成流來消耗來自亞馬遜sqs隊列的消息並且其工作正常。但我想每分鐘或幾秒鐘調整消息的數量。例如每分鐘20條消息。這裏是我的SQL監聽器bean @Bean public MessageProducer mySqsMessageDrivenChannelAdapter() { SqsMessageDrivenChannelAdapter adapter =

0熱度

1回答

在縮放時創建SQS隊列並在縮放時刪除

我試圖讓我的自動縮放組的節點通過SNS和SQS響應事件。這是原題： How to handle wesocket connections on load balanced servers 我想到的解決方案是一個SNS主題，將接收所有事件，如「EntitySaved」。縮放組中的每個節點都會創建一個SQS隊列並將其訂閱到SNS主題。我不知道如何可靠地處理創建和刪除這些隊列作爲縮放組縮放進出。有任