Skip to content
/ go-sqsd Public

Polls an SQS queue and posts messages to an HTTP endpoint. Clone of sqsd from AWS's Elastic Beanstalk

License

Notifications You must be signed in to change notification settings

slank/go-sqsd

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

go-sqsd

Go-sqsd is a clone of the sqsd found on Worker applications in AWS's Elastic Beanstalk PaaS. Given a queue URL and an HTTP endpoint URL, it polls the queue for messages and POSTs them to the endpoint. If the endpoint responds with a 200 response, the message is deleted.

Build/Install

To build the cli:

go install github.com/slank/go-sqsd/cli/sqsd

Usage

usage: sqsd [options] queue_url dest_url

  -http.content_type="application/json": Value of the Content-Type HTTP header
  -sqs.messages_per_request=10: Maximum number of messages to receive per request
  -sqs.poll_wait_seconds=20: Long poll time in seconds
  -sqs.sleep_duration=10s: After an empty receive, wait this long before next poll

AWS credentials are passed via the standard methods (environment variables, user credential files, instance profiles, etc). The AWS CLI docs have a concise description of the various sources. sqsd offers no command-line options for passing AWS credentials.

You may need to set the AWS_REGION environment variable to the region where the SQS queue is defined.

About

Polls an SQS queue and posts messages to an HTTP endpoint. Clone of sqsd from AWS's Elastic Beanstalk

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Contributors 4

  •  
  •  
  •  
  •  

Languages