Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add SQS / SNS Support #35

Open
goliel opened this issue Mar 6, 2024 · 3 comments
Open

Add SQS / SNS Support #35

goliel opened this issue Mar 6, 2024 · 3 comments
Labels
feature New feature or request

Comments

@goliel
Copy link

goliel commented Mar 6, 2024

Websockets are not very good when you want to process a lot of messages in a large pipeline due to the lack of consumers that can process the messages.

Would like to see some kind of SQS support, this way multiple consumers can subscribe and process the messages as scale out rather than scale up.

@d-Rickyy-b
Copy link
Owner

This project was initially thought of as a 1:1 replacement for the original certstream server. I thought about implementing something like Kafka support myself, additionally to websockets.

I haven't worked with SNS / SQS yet so I can't say if that's something I'll consider adding. But I'll definitely have a look into it.

Cheers

@alberts-s
Copy link
Contributor

When I first found this repository I thought at first that having support for a queue (e.g SQS) would be useful.

However after giving this more though - maybe it would be better to prioritize adding support for storing the messages in an S3-compatible file store? Combining this with the out of the box feature to receive S3 events in SQS (guide here) it would also accomplish the goal of supporting SQS. GCP supports similar mechanism out of the box too.

Moreover supporting an S3-compatible store would allow also to easily query results using AWS Athena/Glue and GCP BigQuery.

@d-Rickyy-b d-Rickyy-b added the feature New feature or request label Aug 19, 2024
@meinder-a
Copy link

Well, I thought that having this feature could make it easier to implement other distributed message-queuing services like Kafka, which is also widely used. I'm not entirely sure though. I like the concept of uploading messages to S3, but I’d prefer a small script that reads the messages using Kafka and uploads them to S3 afterwards.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
feature New feature or request
Projects
None yet
Development

No branches or pull requests

4 participants