teskalabs/bspump repository overview

BSPump is a real-time stream processor designed for processing and analyzing of the huge quantities of events. BSPump is fully asynchronous using async/await syntax from Python 3.5, making the processing modern, non-blocking, speedy and hence scalable. We make every effort to build BSPump container-friendly so that you can deploy the microservice to a Docker or Kubernetes in a breeze.

It lives on GitHub: https://github.com/LibertyAces/BitSwanPump⁠

This is "all-on" BSPump repository. It means that all dependencies are pre-installed.

This is a list of enabled technologies:

• bspump.amqp AMQP/RabbitMQ connection, source and sink
• bspump.common
• bspump.crypto
• bspump.elasticsearch ElasticSearch connection, source and sink
• bspump.file (plain files, JSON, CSV)
• bspump.http.client HTTP client source
• bspump.http.web HTTP server source and sink
• bspump.influxdb InfluxDB connection and sink
• bspump.kafka Kafka connection, source and sink
• bspump.mysql MySQL connection, source and sink
• bspump.parquet Apache Parquet file sink
• bspump.avro Apache Avro file source and sink
• bspump.socket TCP source
• bspump.slack Slack connection and sink
• bspump.trigger Opportunistic, PubSub and Periodic triggers
• bspump.analyzer Time Window analyzer
• bspump.lookup GeoIP Lookup

BSPump REST API is also enabled at port TCP/80.