Abstract base classes for a long running, streaming API consumer and a specific implementation that puts the data into a redis queue and processes it in batches.
Requires gevent. The example implementation depends on redis.
Coded initially to send batches of statuses from the Twitter Streaming API to an appengine webhook. May (or may not) be usable for other purposes.
Presumes the data coming down the pipe is Chunked Transfer Encoded.
1 maintainer
Metadata
1 maintainer
Release files for close.consumer 0.2.2
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| close.consumer-0.2.2.tar.gz | 11.2 kB | Details |
Release files / close.consumer-0.2.2.tar.gz
| Download URL | close.consumer-0.2.2.tar.gz |
|---|---|
| Size | 11.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
88a04e46aa8b0411cd19077ddff8f31b26af52b236079fba3611dc191369c640
|
|
BLAKE2b-256 checksum How to use checksums |
1dd2b8d4b357dd1df1949e06ba9deeac2276cd8fee309d2bf3f4073e6bbde5b2
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
