amazon-sqs

    3熱度

    2回答

    我正在使用python Boto3代碼,當一個實例從Auto Scaling組中終止時,它會通知發佈消息到SQS的SNS。當通知SNS時,也會觸發Lambda,它會執行boto腳本以從SQS獲取消息。 我使用的參考碼是Sending and Receiving Messages in Amazon SQS。 這裏是代碼片段: if messages.get('Messages'): m

    1熱度

    1回答

    我一直在努力從AWS隊列中收到一條消息,以便刪除郵件。 我使用的功能是: <cffunction name="deleteMessage" output="true" returntype="void"> <cfargument name="uri" type="string" required="true"> <cfargument name="messageId" type

    0熱度

    1回答

    我通過設在這裏快速入門走了。我安裝了AWS CLI https://boto3.readthedocs.io/en/latest/guide/quickstart.html ,並與本人的有效配置鑰匙它。我已經在〜/ .aws/credentials和〜/ .aws/config中加入了檢查和〜/ .aws/config。在這一點上我應該可以在命令提示符下運行我的py腳本python bin/pro

    -2熱度

    3回答

    我在AWS內部的EC2實例上有一箇中央C#窗口服務。它的任務是創建任務(JSON內部的指令),然後將這些任務發送到運行在AWS以外的服務器上的各個Windows服務(例如,在每個商店中有一個服務器的灰漿零售店)。 這些單獨的服務器根據JSON任務執行一些處理,然後將消息發送回AWS內的中央窗口服務。此設計目前正在使用AWS SQS。 我最初的設計是使用1個SQS隊列消息到外部服務器,1個SQS隊列

    0熱度

    1回答

    我有一個讀取SQS隊列的Mule應用程序。我正試圖找到一種方法來限制我從隊列中讀取數據。 我的要求是限制輪詢之間的時間,也一次只讀取一條消息。 調查隊列如果設置在騾子SQS以下每10秒只有1個新的消息 :將對應於我後收到的消息連接器? pollingPeriod numberOfMessages 我有點不確定從閱讀documenation pollingPeriod是否是SQS長輪詢,這不是我想要

    0熱度

    1回答

    根據文檔(AWS SQS Limits),每個隊列(在標準隊列中)的最大飛行消息數爲120,000。 但SQS是否對隊列中的可用消息有任何限制? 我猜想隊列在SQS中可以保留的消息數量沒有限制,但我還沒有在文檔上找到任何明確的聲明。

    1熱度

    1回答

    我想知道是否有人知道如何在Heroku上運行Supervisor來管理隊列工?我設法爲我的Laravel應用程序在本地運行Supervisor,但不知道如何創建更多工作進程以更快地完成作業隊列。 我問Heroku在這方面的支持,他們說它應該可以工作,但他們沒有任何文檔,我也不認爲他們會幫我解決這個問題。目前,讓更多工作人員進入隊列(我使用SQS)的唯一方法是通過Procfile創建更多進程,您必須

    0熱度

    1回答

    我配置了一個執行SQL語句並將數據轉儲到S3存儲桶的數據管道。管道中的一切工作正常。數據正在成功轉儲。今天,我在Activity上的OnSuccess事件中添加了一個SNSAlarm,併爲該SNS主題訂閱了一個SQS隊列。但是,即使活動成功,我也不會在隊列中收到任何消息,也不會看到任何與SNS成功或失敗相關的日誌。 有沒有人在AWS Datapipeline中使用過SnsAlarm?任何幫助都會很

    0熱度

    1回答

    我們有SQS監聽器,如: @MessageMapping("queueName") void listen(String message) { ... } 此隊列關聯的死信隊列配置重驅動的策略。 問題是默認的Spring Cloud AWS實現在輪詢它時發送消息並在內部進行連線3處理它的重試,然後失敗。 我可以看到有一個SqsMessageDeletionPolicy枚舉ALWAYS和ON_

    0熱度

    1回答

    我創建了一個示例應用程序,用於從AWS SQS隊列中讀取消息。如果重要的話,但是我懷疑。 我設法得到消息的正文並將其寫入數據庫,但我沒有看到其他信息(如屬性)在哪裏? 在一個連接到隊列的工作環境中,當創建一條新消息時,應用程序通過POST被調用,所以我使用req.on('data', function (chunk){...}。 'chunk'包含主體字符串(實際上是Buffer)。 如何找到自定