C#으로 작성된 HTTP 서버가 특정 열린 포트에서 패킷을 받고 AWS SQS (Simple Queue Service)에 패킷을 저장합니다. 현재이 서버 응용 프로그램은 EC2 인스턴스에서 실행 중입니다. 하지만이 서버 응용 프로그램에 대해서만 전체 EC2 인스턴스를 사용하는 것은 나에게 무의미한 것처럼 보입니다. 작업을 수행 할 다른 AWS 서비스가 있습
WebHook에서 특정 헤더의 서명이 나타납니다. Token Body 또는 Attribute에서 SQS로 전달하려고합니다. 다음 구성을 시도했습니다. 그것은 작동하지 않습니다. 나는 무엇을 놓치고 AWS Service : Simple Queue Service (SQS)
HTTP method :POST
Path override :Account/QueueN
많은 큐의 모든 메시지를 단일 "캐치 올"큐로 리디렉션하고 원본 큐 이름을 "원본"이라는 특성으로 추가하여 메시지를 변경하는 쉬운 방법이 있습니까? 단일 대기열 대신 대기열이 필요한 이유는 다음과 같습니다. 개별 소스에 대한 사용자의 액세스를 규제하기 위해 IAM 정책을 사용하고 싶습니다. 편집 : 내가 구축해야하는 것은 매우 간단합니다 : 사용자 S3에
나는 클라이언트 프로그램이 아마존의 API 게이트웨이에있는 API에 자신의 행동을 게시 한 다음, 다른 클라이언트의 행동에 대한 메시지를 수신하는 공동 작업 문서 프로젝트 (기본적으로 Google 문서의 클론)를 만들고있다. SQS 큐. API는 메시지를 생성하는 Node.js 람다 함수를 호출하고이를 SNS에 게시 한 다음 각 클라이언트의 SQS에 통지합
AmazonSQSClient를 사용하여 SQS 서비스와 상호 작용하고 기본 클라이언트 구성을 사용하고 있습니다. 즉, DEFAULT_RETRY_POLICY를 이미 사용하고 있습니다. 자바 코드에서 "sendMessage"메소드를 호출한다고 가정 해 봅니다. doc에 따라 메서드는 두 가지 유형의 예외를 throw 할 수 있습니다. InvalidMessage
내가 akka 스트림을 사용하여 SQS를들을려고하고이 코드를 사용 Q 있어에서 내가 메시지를 얻을 : (다음을 ACK) 물론 이 코드는 메시지를 하나씩 얻을를 : implicit val system = ActorSystem()
implicit val mat = ActorMaterializer()
implicit val ec = ExecutionConte
사용 사례는 다음과 같습니다. 예약 된 메시지를 특정 날짜/시간 및 필요에 따라 반복적으로 대기열에 추가 할 수있는 방법으로 SQS 메시지를 예약 할 수 있어야합니다 . 구현 수준에서 기본적으로 수행해야 할 작업은 SQS 큐, 메시지 및 일정에서 전달할 수있는 일부 함수가 있어야한다는 것입니다. 실제 큐를 작성하지 않고도 실행하고 싶습니다. 스케줄러 논리.
SQS 메시지를 보낼 때마다 람다를 호출하고 싶습니다. 다음 패턴으로 Cloudwatch 이벤트 규칙을 설정하려고했습니다. {
"source": [
"aws.sqs"
]
}
불행히도 lambda는 호출되지 않습니다. 나는 람다의 역할이 SQS 정책을 가지고 있음을 이미 확인했다. 어떻게 할 수 있습니까?