Ecosyste.ms: Repos

An open API service providing repository metadata for many open source software ecosystems.

GitHub topics: sqs-consumer

svix/omniqueue-rs

A Queue Abstraction Layer for Rust (Redis, RabbitMQ, SQS, etc.)

Language: Rust - Size: 516 KB - Last synced: about 9 hours ago - Pushed: about 10 hours ago - Stars: 52 - Forks: 5

Coaktion/evolutty

Evolutty is an asynchronous message dispatcher for concurrent tasks processing.

Language: TypeScript - Size: 570 KB - Last synced: 11 days ago - Pushed: 3 months ago - Stars: 6 - Forks: 1

fgiova/fastify-sqs-consumer

This plugin for fastify 4.x allows you to consume messages from AWS SQS queues. On fastify shutdown a simple wait function is called to wait for the end of the processing of the messages in progress

Language: TypeScript - Size: 126 KB - Last synced: 7 days ago - Pushed: 9 months ago - Stars: 3 - Forks: 0

bbc/sqs-consumer-starter

Examples of how to use sqs-consumer for starting out, or for reproductions

Size: 323 KB - Last synced: 15 days ago - Pushed: 17 days ago - Stars: 1 - Forks: 1

aspecto-io/sns-sqs-big-payload

Amazon SNS/SQS client library that enables sending and receiving messages with payload larger than 256KiB via Amazon S3.

Language: TypeScript - Size: 327 KB - Last synced: 21 days ago - Pushed: 7 months ago - Stars: 51 - Forks: 16

Uchencho/s3Consumer

Writing to s3 with Go and consuming from s3 using AWS SQS events

Language: Go - Size: 7.3 MB - Last synced: about 1 month ago - Pushed: about 3 years ago - Stars: 2 - Forks: 0

Deep1144/serverless-localstack-sqs

A repo showing how to use sqs offline (as producer and consumer) with serverless and localstack

Language: JavaScript - Size: 69.3 KB - Last synced: about 1 month ago - Pushed: about 2 years ago - Stars: 0 - Forks: 0

HexmosTech/aws_sqs_consumer_python

Write Amazon Simple Queue Service (SQS) consumers in Python with simplified interface.

Language: Python - Size: 78.1 KB - Last synced: 27 days ago - Pushed: 10 months ago - Stars: 15 - Forks: 5

kalaspuff/tomodachi

💻 Microservice lib designed to ease service building using Python and asyncio, with ready to use support for HTTP + WS, AWS SNS+SQS, RabbitMQ / AMQP, middlewares, envelopes, logging, lifecycles. Extend to GraphQL, protobuf, etc.

Language: Python - Size: 14.2 MB - Last synced: 16 days ago - Pushed: 18 days ago - Stars: 188 - Forks: 26

mmnavarr/ts-sqs

Local AWS SQS Consumer & Publisher built on NodeJS with TypeScript

Language: TypeScript - Size: 33.2 KB - Last synced: 2 months ago - Pushed: over 3 years ago - Stars: 2 - Forks: 1

gregwhitaker/sqs-priority-client

Reactive wrapper around the Amazon SQS client that allows reading from multiple queues with weighted priority.

Language: Java - Size: 594 KB - Last synced: 2 months ago - Pushed: about 3 years ago - Stars: 3 - Forks: 0

martineli17/.net-aws-sqs-consumer

Produzindo e consumindo mensagem utilizando .NET, SQS e Terraform

Language: C# - Size: 216 KB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

nejdetkadir/sidekiq-aws-sqs

Sidekiq extension that provides an easy way to poll and process messages from AWS SQS (Simple Queue Service) queues within a Sidekiq worker

Language: Ruby - Size: 19.5 KB - Last synced: 14 days ago - Pushed: about 1 year ago - Stars: 23 - Forks: 4

prashanthpai/sqscat

A netcat/kafkacat like utility for AWS SQS.

Language: Go - Size: 30.3 KB - Last synced: 3 months ago - Pushed: about 1 year ago - Stars: 5 - Forks: 0

joisiney/sqs-sns-localstak-decorator-clean-code-nodejs

Projeto inovador centrado em boas praticas com as seguintes tecnologias: LocalStack, SQS, SNS, Fastify e decorators.

Language: TypeScript - Size: 216 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 2 - Forks: 0

buildrun-tech/buildrun-java-aws-sqs-producer-consumer-exemplo

Código utilizado no vídeo em que ensinamos o passo a passo para você criar um consumer e producer de um AWS SQS no Java com Spring Boot e LocalStack.

Language: Java - Size: 70.3 KB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 1 - Forks: 0

jay-johnson/celery-connectors

Want to handle 100,000 messages in 90 seconds? Celery and Kombu are that awesome - Multiple publisher-subscriber demos for processing json or pickled messages from Redis, RabbitMQ or AWS SQS. Includes Kombu message processors using native Producer and Consumer classes as well as ConsumerProducerMixin workers for relay publish-hook or caching

Language: Python - Size: 3.29 MB - Last synced: 13 days ago - Pushed: over 5 years ago - Stars: 40 - Forks: 9

fgiova/sqs-consumer

A sqs-consumer with zero dependencies with aws-sdk, undici for http calls, and a no-blocking signature system

Language: TypeScript - Size: 527 KB - Last synced: about 1 month ago - Pushed: 4 months ago - Stars: 8 - Forks: 0

fgiova/mini-sqs-client

Mini sqs client using unidici as http agent

Language: TypeScript - Size: 159 KB - Last synced: 4 months ago - Pushed: 5 months ago - Stars: 1 - Forks: 0

GabrielHCataldo/go-aws-sqs-template

✉️ Powerful AWS SQS Template, with all functions and interactions optimized and simple to use.

Language: Go - Size: 191 KB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

allisson/pysqsx

A simple task processor for Amazon SQS

Language: Python - Size: 89.8 KB - Last synced: 16 days ago - Pushed: about 1 month ago - Stars: 4 - Forks: 0

miztiik/reliable-sqs-with-dlq

Reliably process messages in queue with dead-letter queues in SQS

Language: Python - Size: 1020 KB - Last synced: 24 days ago - Pushed: over 3 years ago - Stars: 3 - Forks: 1

miztiik/reliable-queues-with-retry-dlq

Reliable Message Processing with Dead-Letter-Queues Replay

Language: Python - Size: 923 KB - Last synced: 24 days ago - Pushed: about 3 years ago - Stars: 10 - Forks: 3

JavatoDev-com/amazon-sqs-spring-boot-application

How to Use Amazon SQS With Spring Boot

Language: Java - Size: 65.4 KB - Last synced: 4 months ago - Pushed: 7 months ago - Stars: 4 - Forks: 1

DataGreed/django-eb-sqs-worker

Django Background Tasks for Amazon Elastic Beanstalk

Language: Python - Size: 231 KB - Last synced: 12 days ago - Pushed: about 2 years ago - Stars: 32 - Forks: 8

saifkhan192/aws-cloudformation-ecs-container-load-balancer

Dockerized exppress js app and sqs worker with CI/CD Code Pipeline.

Language: TypeScript - Size: 396 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 0

pablofelitti/telegram-sender

Telegram message sender

Language: Rust - Size: 85.3 MB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 1 - Forks: 0

andresWeitzel/SQS_Nodejs_AWS

Modelo para el uso de Amazon SQS implementado con Nodejs, Serverless-offline, Amazon SQS, Amazon Api-Gateway, Aws-lambda, etc

Language: JavaScript - Size: 27.8 MB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

DariuszWietecha/node-sqs-soap-nmbrsapi-workflow

Node microservice that consumes SQS messages, retrieves data from api.nmbrs.nl API and saves it as JSON files with the required structure.

Language: TypeScript - Size: 58.6 KB - Last synced: 10 months ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0

MDalfre/sr-sqs

Simple generic Amazon SQS client and mock, designed to make asynchronous applications that uses SQS queues simple to test.

Language: Kotlin - Size: 1.1 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 4 - Forks: 0

joeycumines/go-faucet

Implements a simple pattern for polling based rate limiting, using Golang's time.Ticker.

Language: Go - Size: 14.6 KB - Last synced: 10 months ago - Pushed: almost 6 years ago - Stars: 0 - Forks: 0

mseld/sqs-consumer

sqs-consumer

Language: Go - Size: 35.2 KB - Last synced: 10 months ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

olafrv/rmq_sqs_bridge

(DRAFT) Simple RabbitMQ and AWS SQS message bridge

Language: Python - Size: 6.84 KB - Last synced: 12 months ago - Pushed: 12 months ago - Stars: 0 - Forks: 0

kpavlov/spring-reactive-messaging

Reactive messaging SQS producer/consumer inspired by Spring Messaging and Spring Integration, implemented using Project Reactor.

Language: Kotlin - Size: 31.3 KB - Last synced: 16 days ago - Pushed: over 1 year ago - Stars: 1 - Forks: 0

desertCoder01/spring-dynamodb

Spring project using amazon dynamodb

Language: Java - Size: 39.1 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

rocketseat-creators-program/Localstack-Webflux-Criando-um-consumer-SQS-localmente-2021-10-12

Nessa aula vamos aprender como utilizar o localstack que é um emulador de serviços AWS para desenvolver um consumer SQS com Webflux e AWS SDK

Language: Java - Size: 54.7 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 3 - Forks: 0

kouky/rust-concurrent-sqs-worker

Language: Rust - Size: 15.6 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 1 - Forks: 0

sshivananda/ts-sqs-consumer

Typescript based sqs consumer

Language: TypeScript - Size: 604 KB - Last synced: 29 days ago - Pushed: about 1 month ago - Stars: 3 - Forks: 2

minimice/stock-prices-app

Real time streaming stock prices using the Intrinio SDK built using distributed architecture

Language: JavaScript - Size: 1.18 MB - Last synced: 8 months ago - Pushed: about 5 years ago - Stars: 1 - Forks: 0

jcmdsbr/rebus-sqs Fork of rebus-org/Rebus.AmazonSQS

:bus: Amazon SQS transport for Rebus

Language: C# - Size: 3.11 MB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

rootstream/_ARCHIVED-sqs-rpc 📦

RPC solution based on AWS SQS queues

Language: JavaScript - Size: 124 KB - Last synced: 22 days ago - Pushed: over 4 years ago - Stars: 2 - Forks: 1

academy-software/go-aws-sqs-consumer

Go library to consume messages from AWS' SQS

Language: Go - Size: 31.3 KB - Last synced: 10 months ago - Pushed: about 3 years ago - Stars: 3 - Forks: 0

jairovadillo/razemax

👑 aka. Reis Mags ✉️ Async communications using AWS SNS + SQS for Python ✨

Language: Python - Size: 48.8 KB - Last synced: 14 days ago - Pushed: over 3 years ago - Stars: 7 - Forks: 1

Deenbe/blaster

Web hooks for message queues

Language: Go - Size: 202 KB - Last synced: 9 months ago - Pushed: about 1 year ago - Stars: 14 - Forks: 2

remind101/mq-go

SQS Consumer Server for Go

Language: Go - Size: 355 KB - Last synced: 10 months ago - Pushed: almost 6 years ago - Stars: 28 - Forks: 10

eduardo3g/terraform-serverless

Create immutable infrastructure with IaC technologies at AWS with Terraform and Serverless Framework ☁️ The main services used are DynamoDB, SNS, SQS, Lambda, API Gateway, and SSM Parameter Store.

Language: HCL - Size: 98.6 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 8 - Forks: 2

madeiramadeirabr/template-serverless-lambda-python

Template com exemplos de boilerplates para a criação de aplicações para lambda com Python.

Language: Shell - Size: 4.57 MB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 5 - Forks: 3

thiyagu06/reactive-sqs-consumer

reactive sqs consumer using kotlin flow.

Language: Kotlin - Size: 162 KB - Last synced: 11 months ago - Pushed: about 1 year ago - Stars: 2 - Forks: 0

arabog/simple-queue-service

Amazon Simple Queue Service (SQS) is a fully managed message queuing service that allows you to integrate queuing functionality in your application. SQS offers two types of message queues: standard and FIFO.

Size: 377 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0

SeekerWing/aws-sqs-consumer

The AWS SQS Consumer reduces time to launch a SQS Message Consumer, by empowering developers to focus on business logic of consuming the message.

Language: Kotlin - Size: 855 KB - Last synced: 10 months ago - Pushed: about 1 year ago - Stars: 25 - Forks: 6

dalmarcogd/gwp

This library give a implementation to work with workers.

Language: Go - Size: 1.23 MB - Last synced: 10 months ago - Pushed: almost 4 years ago - Stars: 3 - Forks: 2

AnthonyHonstain/springboot-rest-service-prototype

Experimental Spring Boot service used for evaluating strategies for consuming SQS and publishing to ActiveMQ. Along with some different monitoring approaches.

Language: Kotlin - Size: 432 KB - Last synced: about 1 year ago - Pushed: about 2 years ago - Stars: 0 - Forks: 0

ndthuan/aws-sqs-wrapper

PHP library for simplified SQS queue messages processing

Language: PHP - Size: 486 KB - Last synced: 4 months ago - Pushed: over 5 years ago - Stars: 2 - Forks: 0

andrealombardi/gotopic

Receive SNS notifications in your terminal

Language: Go - Size: 8.79 KB - Last synced: about 1 month ago - Pushed: about 2 years ago - Stars: 1 - Forks: 0

Ratkovski/Poc-Java-Sqs-DynamoDB-Consumer-

Simple demo application using Localstack.

Language: Java - Size: 63.5 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 2

Ratkovski/poc-orangeConsumer

Language: Java - Size: 57.6 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

social9/go-queues

A scalable and generic producer-consumer service written in Go

Language: Go - Size: 38.1 KB - Last synced: 10 months ago - Pushed: over 3 years ago - Stars: 1 - Forks: 4

tamdilip/spring-boot-sqs-queue-handler

Sample spring boot app to produce and listen to AWS SQS Queue.

Language: Java - Size: 52.7 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 0 - Forks: 0

realies/sqs-insight-docker

🐳 SQS Insight Simple Queue Service Web Interface Docker Container

Language: Shell - Size: 5.86 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 1 - Forks: 2

hjpotter92/sqspy

Python rewrite of pySqsListener

Language: Python - Size: 50.8 KB - Last synced: 16 days ago - Pushed: about 3 years ago - Stars: 0 - Forks: 1

affix/openfaas-sqs-connector

An SQS Connector for OpenFaaS

Language: Go - Size: 288 KB - Last synced: about 1 month ago - Pushed: over 4 years ago - Stars: 3 - Forks: 3

koslib/go-sqs-worker

SQS wrapper to help you publish and listen to messages in your Go services

Language: Go - Size: 6.84 KB - Last synced: 9 months ago - Pushed: about 3 years ago - Stars: 1 - Forks: 1

rafaelhenrique/simple-sqs-consumer

Consume an AWS SQS queue with Loafer

Language: Python - Size: 3.91 KB - Last synced: about 1 year ago - Pushed: over 5 years ago - Stars: 2 - Forks: 0

kbariotis/sqs-lambda-consumer

Create a sequential pipeline of processing messages with AWS SQS and Lambda.

Language: JavaScript - Size: 5.86 KB - Last synced: about 1 month ago - Pushed: about 5 years ago - Stars: 8 - Forks: 1

PaulWarnick21/WonderQ

WonderQ is a simplified version of Amazon's SQS. This repository includes the WonderQ queue itself that handles adding messages from producers, sending messages to consumers and deleting messages from the queue once the consumer has finished processing the data. I've also included a simple producer and consumer for demonstration .

Language: JavaScript - Size: 18.6 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

cookiemonsterproject/aws-sqs-jar

Jar for AWS SQS consuming.

Language: Go - Size: 10.7 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 1 - Forks: 0

thiagofarbo/api-queue-sqs

This API aims to manage queues.

Language: Java - Size: 54.7 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

sh4hids/test-sqs-and-lambda-locally

Language: JavaScript - Size: 2.93 KB - Last synced: about 1 year ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

kharemohit786/park-meter

Image processing with aws

Language: Java - Size: 183 KB - Last synced: about 1 year ago - Pushed: almost 5 years ago - Stars: 0 - Forks: 0

aatish-sai/aws-php-sqs

Create, receive and delete message for AWS SQS using php

Language: PHP - Size: 10.7 KB - Last synced: about 1 year ago - Pushed: almost 5 years ago - Stars: 0 - Forks: 0

andrewnester/sqslisten

SQSListen, a simple listener for AWS SQS queue.

Language: Rust - Size: 7.81 KB - Last synced: 5 days ago - Pushed: about 5 years ago - Stars: 0 - Forks: 2