amazon-sqs

    1熱度

    1回答

    我試圖使用aws SQS從一批5中接收SQS消息,並希望使5個不同的子進程,以便每個同時運行,當他們中的一個完成作業會回到父進程,然後父進程可以從aws SQS調用另一個作業。同樣,這將使晚五組的工作目前在服務器上運行 編寫的代碼是: const app = Consumer.create({ queueUrl: 'QUEUE_URL', batchSize: 5,

    2熱度

    2回答

    我們計劃使用AWS SQS服務對從Web服務創建的事件進行排隊,然後使用多個工作人員來處理這些事件。一個事件只能處理一次。根據AWS SQS文檔,AWS SQS標準隊列可以「偶爾」產生重複消息,但吞吐量無限。 AWS SQS FIFO隊列不會產生重複消息,但吞吐量限制爲每秒300個API調用(batchSize = 10,相當於每秒3000條消息)。我們目前的高峯時間流量僅爲每秒80條消息。所以,

    0熱度

    1回答

    我有一個Spring Boot項目用於接收來自Amazon SQS隊列的事件。我一直在使用Spring Cloud AWS項目來簡化這一過程。 問題是這樣的:Spring Boot應用程序啓動就好了,似乎實例化所有必要的bean就好了。但是,當調用使用SqsListener註釋的方法時,所有事件處理程序的相關Bean都爲null。 另一件值得注意的事情是:我有兩種傳播事件的方法:1)通過POST

    0熱度

    1回答

    我在Laravel做項目。爲了存儲圖像,我使用aws-s3。我的項目在godaddy服務器上運行得非常好,但不在數字海洋服務器上運行。我得到錯誤的, Aws\Sqs\Exception\SqsException: Error executing "ReceiveMessage" on "https://sqs.us-east-1.amazonaws.com/your-account-id/your

    0熱度

    2回答

    我剛開始使用AWS SDK for Java和.net。 當前我正在創建一個AWS SQS隊列。我能夠創建一個QUEUE,列出現有的隊列,並使用.net SDK與隊列交談。 當我嘗試相同的Java我得到以下錯誤。 無法通過區域提供程序鏈找到區域。必須在構建器或設置環境中提供 顯式區域以提供 區域。 我已經在eclipse中的aws偏好設置中設置了所有必要的訪問鍵,Region和憑證。 我這是如何初

    2熱度

    1回答

    我工作的一個POC在那裏我有設置在S3生命週期規則來移動物體天的某些沒有經過冰川(如果對象已指定標籤)。規則正在爲我好,對象越來越受生命週期規則搬到冰川和存儲類型將改變爲冰川從標準。 (到現在爲止還挺好)。因爲我需要限制用戶從我的應用程序使用該文件(存檔文件),我正在尋找一種方法來獲取通知(通過SQS)或調用Lambda函數(用於調用我的應用程序REST端點),當對象實際上是移動到冰川。 我檢查了

    0熱度

    1回答

    我有兩個彈性beanstalk環境。 一個是'主'Web服務器環境,另一個是處理cron作業的工作環境。 我有12個cron作業,通過cron.yaml文件進行安裝,所有文件都指向主Web服務器上的API端點。 以前我的cron作業都在Web服務器環境中運行,當然這會在這個擴展時創建重複的cron作業。 我的新實現很好地工作,但是在我的cron作業無法按預期運行的情況下,cron作業重複執行,通常

    0熱度

    1回答

    我切換到FIFO隊列,當我試圖從隊列 Value {VALUE} for parameter ReceiptHandle is invalid. Reason: The receipt handle has expired. 看來,發生錯誤的刪除消息,我得到這個錯誤信息因爲我試圖在visibility timeout過期後刪除該郵件。我將默認可見性超時0更改爲最長12小時,這部分解決了問題。有

    0熱度

    1回答

    如果我通過Cloudformation創建SQS隊列,是否可以在SQS隊列創建後附加第二個QueuePolicy? 如果我不運行這個配置如下: Resources: SQSQueue: Properties: QueueName: !Ref SQSQueuename Type: 'AWS::SQS::Queue' QueuePolicy:

    0熱度

    1回答

    ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(queueURL); List<com.amazonaws.services.sqs.model.Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();