A wrapper around AWS Kinesis Firehose with retry logic and custom queuing behavior.
es5 version of firehoser. A wrapper around AWS Kinesis Firehose with retry logic and custom queuing behavior.
Command line tool that automates the setup of a lambda function that fowards records from Kinesis to Firehose.
AWS Kinesis Data Firehose utilities for Rust
bimm dataloader / processing pipeline
bunsen dataloader / processing pipeline
Schema generation macros
Firehose service implementation for winterbaume
Chain-agnostic EVM execution tracer producing Firehose protobuf blocks
bimm-firehose image processing support
bimm-firehose image processing support
AT Protocol firehose consumer: subscribeRepos relay subscription with CAR decoding for at-rust-go
Support crate for Jetstreamer containing firehose ingestion engine and core abstractions
AWS SDK for Amazon Kinesis Firehose
Decode bluesky firehose messages
Official AWS Ruby gem for Amazon Kinesis Firehose (Firehose). This gem is part of the AWS SDK for Ruby.
Fluentd output plugin for Amazon Kinesis Firehose.
Fires events down a hose towards the Great Unknown.
TweetHose lets you easily generate a daemon that listens to the Twitter firehose. When keywords you're interested in appears, you can set up a callback. Should make it easy to create that Justin Bieber tracking app you've always wanted.
Sends records to Firehose, automatically honors the limits
An easy way to get your data sent to Amazon Firehose
Fluentd output plugin that sends events to Amazon Kinesis Firehose.
Skyfall is a Ruby library for connecting to the "firehose" of the Bluesky social network, i.e. a websocket which streams all new posts and everything else happening on the Bluesky network in real time. The code connects to the websocket endpoint, decodes the messages which are encoded in some binary formats, and returns the data as Ruby objects, which you can filter and save to some kind of database (e.g. in order to create a custom feed).
Firehose is a realtime web application toolkit for building realtime Ruby web applications.
Full-featured Ruby client for the Firehose API — tap management, rules CRUD (create, read, update, delete), SSE streaming with auto-reconnect and offset tracking.
Hot Potato is an open source real-time processing framework written in Ruby. Originally designed to process the Twitter firehose at 3,000+ tweets per second, it has been extended to support any type of streaming data as input or output to the framework. The framework excels with applications such as, social media analysis, log processing, fraud prevention, spam detection, instant messaging, and many others that include the processing of streaming data.