Skip to main content

faust

Python Stream Processing Fork

python versions version codecov slack Code style: black pre-commit license downloads

Installation

pip install faust-streaming

Documentation

Why the fork

We have decided to fork the original Faust project because there is a critical process of releasing new versions which causes uncertainty in the community. Everybody is welcome to contribute to this fork, and you can be added as a maintainer.

We want to:

  • Ensure continues release
  • Code quality
  • Use of latest versions of kafka drivers (for now only aiokafka)
  • Support kafka transactions
  • Update the documentation

and more...

Usage

# Python Streams
# Forever scalable event processing & in-memory durable K/V store;
# as a library w/ asyncio & static typing.
import faust

Faust is a stream processing library, porting the ideas from Kafka Streams to Python.

It is used at Robinhood to build high performance distributed systems and real-time data pipelines that process billions of events every day.

Faust provides both stream processing and event processing, sharing similarity with tools such as Kafka Streams, Apache Spark, Storm, Samza, Flink,

It does not use a DSL, it's just Python! This means you can use all your favorite Python libraries when stream processing: NumPy, PyTorch, Pandas, NLTK, Django, Flask, SQLAlchemy, ++

Faust requires Python 3.6 or later for the new async/await_ syntax, and variable type annotations.

Here's an example processing a stream of incoming orders:

app = faust.App('myapp', broker='kafka://localhost')

# Models describe how messages are serialized:
# {"account_id": "3fae-...", amount": 3}
class Order(faust.Record):
    account_id: str
    amount: int

@app.agent(value_type=Order)
async def order(orders):
    async for order in orders:
        # process infinite stream of orders.
        print(f'Order for {order.account_id}: {order.amount}')

The Agent decorator defines a "stream processor" that essentially consumes from a Kafka topic and does something for every event it receives.

The agent is an async def function, so can also perform other operations asynchronously, such as web requests.

This system can persist state, acting like a database. Tables are named distributed key/value stores you can use as regular Python dictionaries.

Tables are stored locally on each machine using a super fast embedded database written in C++, called RocksDB.

Tables can also store aggregate counts that are optionally "windowed" so you can keep track of "number of clicks from the last day," or "number of clicks in the last hour." for example. Like Kafka Streams, we support tumbling, hopping and sliding windows of time, and old windows can be expired to stop data from filling up.

For reliability, we use a Kafka topic as "write-ahead-log". Whenever a key is changed we publish to the changelog. Standby nodes consume from this changelog to keep an exact replica of the data and enables instant recovery should any of the nodes fail.

To the user a table is just a dictionary, but data is persisted between restarts and replicated across nodes so on failover other nodes can take over automatically.

You can count page views by URL:

# data sent to 'clicks' topic sharded by URL key.
# e.g. key="http://example.com" value="1"
click_topic = app.topic('clicks', key_type=str, value_type=int)

# default value for missing URL will be 0 with `default=int`
counts = app.Table('click_counts', default=int)

@app.agent(click_topic)
async def count_click(clicks):
    async for url, count in clicks.items():
        counts[url] += count

The data sent to the Kafka topic is partitioned, which means the clicks will be sharded by URL in such a way that every count for the same URL will be delivered to the same Faust worker instance.

Faust supports any type of stream data: bytes, Unicode and serialized structures, but also comes with "Models" that use modern Python syntax to describe how keys and values in streams are serialized:

# Order is a json serialized dictionary,
# having these fields:

class Order(faust.Record):
    account_id: str
    product_id: str
    price: float
    quantity: float = 1.0

orders_topic = app.topic('orders', key_type=str, value_type=Order)

@app.agent(orders_topic)
async def process_order(orders):
    async for order in orders:
        # process each order using regular Python
        total_price = order.price * order.quantity
        await send_order_received_email(order.account_id, order)

Faust is statically typed, using the mypy type checker, so you can take advantage of static types when writing applications.

The Faust source code is small, well organized, and serves as a good resource for learning the implementation of Kafka Streams.

Learn more about Faust in the introduction introduction page to read more about Faust, system requirements, installation instructions, community resources, and more.

or go directly to the quickstart tutorial to see Faust in action by programming a streaming application.

then explore the User Guide for in-depth information organized by topic.

Local development

  1. Clone the project
  2. Create a virtualenv: python3.7 -m venv venv && source venv/bin/activate
  3. Install the requirements: ./scripts/install
  4. Run lint: ./scripts/lint
  5. Run tests: ./scripts/tests

Faust key points

Simple

Faust is extremely easy to use. To get started using other stream processing solutions you have complicated hello-world projects, and infrastructure requirements. Faust only requires Kafka, the rest is just Python, so If you know Python you can already use Faust to do stream processing, and it can integrate with just about anything.

Here's one of the easier applications you can make::

import faust

class Greeting(faust.Record):
    from_name: str
    to_name: str

app = faust.App('hello-app', broker='kafka://localhost')
topic = app.topic('hello-topic', value_type=Greeting)

@app.agent(topic)
async def hello(greetings):
    async for greeting in greetings:
        print(f'Hello from {greeting.from_name} to {greeting.to_name}')

@app.timer(interval=1.0)
async def example_sender(app):
    await hello.send(
        value=Greeting(from_name='Faust', to_name='you'),
    )

if __name__ == '__main__':
    app.main()

You're probably a bit intimidated by the async and await keywords, but you don't have to know how asyncio works to use Faust: just mimic the examples, and you'll be fine.

The example application starts two tasks: one is processing a stream, the other is a background thread sending events to that stream. In a real-life application, your system will publish events to Kafka topics that your processors can consume from, and the background thread is only needed to feed data into our example.

Highly Available

Faust is highly available and can survive network problems and server crashes. In the case of node failure, it can automatically recover, and tables have standby nodes that will take over.

Distributed

Start more instances of your application as needed.

Fast

A single-core Faust worker instance can already process tens of thousands of events every second, and we are reasonably confident that throughput will increase once we can support a more optimized Kafka client.

Flexible

Faust is just Python, and a stream is an infinite asynchronous iterator. If you know how to use Python, you already know how to use Faust, and it works with your favorite Python libraries like Django, Flask, SQLAlchemy, NLTK, NumPy, SciPy, TensorFlow, etc.

Bundles

Faust also defines a group of setuptools extensions that can be used to install Faust and the dependencies for a given feature.

You can specify these in your requirements or on the pip command-line by using brackets. Separate multiple bundles using the comma:

pip install "faust-streaming[rocksdb]"

pip install "faust-streaming[rocksdb,uvloop,fast,redis,aerospike]"

The following bundles are available:

Faust with extras

Stores

RocksDB

For using RocksDB for storing Faust table state. Recommended in production.

pip install faust-streaming[rocksdb] (uses RocksDB 6)

pip install faust-streaming[rocksdict] (uses RocksDB 8, not backwards compatible with 6)

Aerospike

pip install faust-streaming[aerospike] for using Aerospike for storing Faust table state. Recommended if supported

Aerospike Configuration

Aerospike can be enabled as the state store by specifying store="aerospike://"

By default, all tables backed by Aerospike use use_partitioner=True and generate changelog topic events similar to a state store backed by RocksDB. The following configuration options should be passed in as keys to the options parameter in Table namespace : aerospike namespace

ttl: TTL for all KV's in the table

username: username to connect to the Aerospike cluster

password: password to connect to the Aerospike cluster

hosts : the hosts parameter as specified in the aerospike client

policies: the different policies for read/write/scans policies

client: a dict of host and policies defined above

Caching

faust-streaming[redis] for using Redis as a simple caching backend (Memcached-style).

Codecs

faust-streaming[yaml] for using YAML and the PyYAML library in streams.

Optimization

faust-streaming[fast] for installing all the available C speedup extensions to Faust core.

Sensors

faust-streaming[datadog] for using the Datadog Faust monitor.

faust-streaming[statsd] for using the Statsd Faust monitor.

faust-streaming[prometheus] for using the Prometheus Faust monitor.

Event Loops

faust-streaming[uvloop] for using Faust with uvloop.

faust-streaming[eventlet] for using Faust with eventlet

Debugging

faust-streaming[debug] for using aiomonitor to connect and debug a running Faust worker.

faust-streaming[setproctitle]when the setproctitle module is installed the Faust worker will use it to set a nicer process name in ps/top listings.vAlso installed with the fast and debug bundles.

Downloading and installing from source

Download the latest version of Faust from https://pypi.org/project/faust-streaming/

You can install it by doing:

$ tar xvfz faust-streaming-0.0.0.tar.gz
$ cd faust-streaming-0.0.0
$ python setup.py build
# python setup.py install

The last command must be executed as a privileged user if you are not currently using a virtualenv.

Using the development version

With pip

You can install the latest snapshot of Faust using the following pip command:

pip install https://github.com/faust-streaming/faust/zipball/master#egg=faust

FAQ

Can I use Faust with Django/Flask/etc

Yes! Use eventlet as a bridge to integrate with asyncio.

Using eventlet

This approach works with any blocking Python library that can work with eventlet

Using eventlet requires you to install the faust-aioeventlet module, and you can install this as a bundle along with Faust:

pip install -U faust-streaming[eventlet]

Then to actually use eventlet as the event loop you have to either use the -L <faust --loop> argument to the faust program:

faust -L eventlet -A myproj worker -l info

or add import mode.loop.eventlet at the top of your entry point script:

#!/usr/bin/env python3
import mode.loop.eventlet  # noqa

It's very important this is at the very top of the module, and that it executes before you import libraries.

Can I use Faust with Tornado

Yes! Use the tornado.platform.asyncio bridge

Can I use Faust with Twisted

Yes! Use the asyncio reactor implementation: https://twistedmatrix.com/documents/current/api/twisted.internet.asyncioreactor.html

Will you support Python 2.7 or Python 3.5

No. Faust requires Python 3.10 or later, since it heavily uses features that were introduced in Python 3.6 (async, await, variable type annotations).

I get a maximum number of open files exceeded error by RocksDB when running a Faust app locally. How can I fix this

You may need to increase the limit for the maximum number of open files. On macOS and Linux you can use:

ulimit -n max_open_files to increase the open files limit to max_open_files.

On docker, you can use the --ulimit flag:

docker run --ulimit nofile=50000:100000 <image-tag> where 50000 is the soft limit, and 100000 is the hard limit See the difference.

What kafka versions faust supports

Faust supports kafka with version >= 0.10.

Getting Help

Slack

For discussions about the usage, development, and future of Faust, please join the fauststream Slack.

Resources

Bug tracker

If you have any suggestions, bug reports, or annoyances please report them to our issue tracker at https://github.com/faust-streaming/faust/issues/

License

This software is licensed under the New BSD License. See the LICENSE file in the top distribution directory for the full license text.

Contributing

Development of Faust happens at GitHub

You're highly encouraged to participate in the development of Faust.

Code of Conduct

Everyone interacting in the project's code bases, issue trackers, chat rooms, and mailing lists is expected to follow the Faust Code of Conduct.

As contributors and maintainers of these projects, and in the interest of fostering an open and welcoming community, we pledge to respect all people who contribute through reporting issues, posting feature requests, updating documentation, submitting pull requests or patches, and other activities.

We are committed to making participation in these projects a harassment-free experience for everyone, regardless of level of experience, gender, gender identity and expression, sexual orientation, disability, personal appearance, body size, race, ethnicity, age, religion, or nationality.

Examples of unacceptable behavior by participants include:

  • The use of sexualized language or imagery
  • Personal attacks
  • Trolling or insulting/derogatory comments
  • Public or private harassment
  • Publishing other's private information, such as physical or electronic addresses, without explicit permission
  • Other unethical or unprofessional conduct.

Project maintainers have the right and responsibility to remove, edit, or reject comments, commits, code, wiki edits, issues, and other contributions that are not aligned to this Code of Conduct. By adopting this Code of Conduct, project maintainers commit themselves to fairly and consistently applying these principles to every aspect of managing this project. Project maintainers who do not follow or enforce the Code of Conduct may be permanently removed from the project team.

This code of conduct applies both within project spaces and in public spaces when an individual is representing the project or its community.

Instances of abusive, harassing, or otherwise unacceptable behavior may be reported by opening an issue or contacting one or more of the project maintainers.

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

faust_streaming-0.13.2.tar.gz (823.6 kB view details)

Uploaded Source

Built Distributions

If you're not sure about the file name format, learn more about wheel file names.

faust_streaming-0.13.2-cp314-cp314-win_amd64.whl (848.5 kB view details)

Uploaded CPython 3.14Windows x86-64

faust_streaming-0.13.2-cp314-cp314-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl (1.3 MB view details)

Uploaded CPython 3.14manylinux: glibc 2.17+ x86-64manylinux: glibc 2.5+ x86-64

faust_streaming-0.13.2-cp314-cp314-macosx_11_0_arm64.whl (532.4 kB view details)

Uploaded CPython 3.14macOS 11.0+ ARM64

faust_streaming-0.13.2-cp314-cp314-macosx_10_15_x86_64.whl (543.9 kB view details)

Uploaded CPython 3.14macOS 10.15+ x86-64

faust_streaming-0.13.2-cp313-cp313-win_amd64.whl (844.9 kB view details)

Uploaded CPython 3.13Windows x86-64

faust_streaming-0.13.2-cp313-cp313-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl (1.3 MB view details)

Uploaded CPython 3.13manylinux: glibc 2.17+ x86-64manylinux: glibc 2.5+ x86-64

faust_streaming-0.13.2-cp313-cp313-macosx_11_0_arm64.whl (531.2 kB view details)

Uploaded CPython 3.13macOS 11.0+ ARM64

faust_streaming-0.13.2-cp313-cp313-macosx_10_13_x86_64.whl (543.5 kB view details)

Uploaded CPython 3.13macOS 10.13+ x86-64

faust_streaming-0.13.2-cp312-cp312-win_amd64.whl (846.2 kB view details)

Uploaded CPython 3.12Windows x86-64

faust_streaming-0.13.2-cp312-cp312-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl (1.3 MB view details)

Uploaded CPython 3.12manylinux: glibc 2.17+ x86-64manylinux: glibc 2.5+ x86-64

faust_streaming-0.13.2-cp312-cp312-macosx_11_0_arm64.whl (533.7 kB view details)

Uploaded CPython 3.12macOS 11.0+ ARM64

faust_streaming-0.13.2-cp312-cp312-macosx_10_13_x86_64.whl (545.0 kB view details)

Uploaded CPython 3.12macOS 10.13+ x86-64

faust_streaming-0.13.2-cp311-cp311-win_amd64.whl (845.8 kB view details)

Uploaded CPython 3.11Windows x86-64

faust_streaming-0.13.2-cp311-cp311-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl (1.2 MB view details)

Uploaded CPython 3.11manylinux: glibc 2.17+ x86-64manylinux: glibc 2.5+ x86-64

faust_streaming-0.13.2-cp311-cp311-macosx_11_0_arm64.whl (533.7 kB view details)

Uploaded CPython 3.11macOS 11.0+ ARM64

faust_streaming-0.13.2-cp311-cp311-macosx_10_9_x86_64.whl (542.9 kB view details)

Uploaded CPython 3.11macOS 10.9+ x86-64

faust_streaming-0.13.2-cp310-cp310-win_amd64.whl (845.8 kB view details)

Uploaded CPython 3.10Windows x86-64

faust_streaming-0.13.2-cp310-cp310-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl (1.2 MB view details)

Uploaded CPython 3.10manylinux: glibc 2.17+ x86-64manylinux: glibc 2.5+ x86-64

faust_streaming-0.13.2-cp310-cp310-macosx_11_0_arm64.whl (534.0 kB view details)

Uploaded CPython 3.10macOS 11.0+ ARM64

faust_streaming-0.13.2-cp310-cp310-macosx_10_9_x86_64.whl (543.3 kB view details)

Uploaded CPython 3.10macOS 10.9+ x86-64

File details

Details for the file faust_streaming-0.13.2.tar.gz.

File metadata

  • Download URL: faust_streaming-0.13.2.tar.gz
  • Upload date:
  • Size: 823.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? Yes
  • Uploaded via: twine/7.0.0 CPython/3.13.14

File hashes

Hashes for faust_streaming-0.13.2.tar.gz
Algorithm Hash digest
SHA256 66c6de821911f4cfabda789a5e666b58daa31c4e2612819353981314f7276cc6
MD5 9f5e685d785efc49be9965fca27b7670
BLAKE2b-256 fc7c09281403f31113c792b913cabdccb7bfd637ad92f21b33ab78630bf84ca5

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2.tar.gz:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp314-cp314-win_amd64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp314-cp314-win_amd64.whl
Algorithm Hash digest
SHA256 9144c7aa133514e4290a01c56e39e47fac1ee6e7a0b76f1db5f1e6b4cab1d12a
MD5 07d0a36a54fc99cb8fae5fa5a40a59a6
BLAKE2b-256 3c7484845109f9fb11c4e39b7e739666698aa8a9657d147fba47ad9aa7e89434

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp314-cp314-win_amd64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp314-cp314-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp314-cp314-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl
Algorithm Hash digest
SHA256 d7d7b91eb3841bff8b3fee987c86e2542accbf1cc4f4ec754ebbb6c3d5cf1860
MD5 ed5724e31a3605449f394f2658f879f4
BLAKE2b-256 11ec51a63287f15b143a16a29cbcbcb51d3d58c7fcfb1b51134751e2b62e710c

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp314-cp314-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp314-cp314-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp314-cp314-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 1bac574c040111542185dd1d0ffde4fcc38a35e978295e73c7a20b094e09361e
MD5 556ae2b4bd69fcbd3cb2d30ebb77a778
BLAKE2b-256 8a1247f86192dd864e2adefddb2e40fc7345e6526778c97eec51b2ee67ae4e4e

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp314-cp314-macosx_11_0_arm64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp314-cp314-macosx_10_15_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp314-cp314-macosx_10_15_x86_64.whl
Algorithm Hash digest
SHA256 6119c824dbc52e36f64f86f5619e6a8be5050669e157b15f00d450db0108e42d
MD5 e3bdd5007d9b706693f6c97aa7a06fdc
BLAKE2b-256 f4076a96db5cd22c372888069a46ea65fe4c924fdd1977442cb5f88e433696cb

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp314-cp314-macosx_10_15_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp313-cp313-win_amd64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp313-cp313-win_amd64.whl
Algorithm Hash digest
SHA256 43c091428450ebd0566c633001f8f752bd5ef80e261c704172675d493d74137c
MD5 8d5bc6420e75b44cb337adce0a343b32
BLAKE2b-256 6296cf5968f979e3b49eb52d63b30fbaeccc7b9db3c882693e31d736d2c22ef0

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp313-cp313-win_amd64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp313-cp313-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp313-cp313-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl
Algorithm Hash digest
SHA256 251de7c974d6e62561a0f8c75a5e2962822117ca8890644c5fddcd39c16f299b
MD5 9e64172b417bce641054bf660741dc41
BLAKE2b-256 651bfb489f71153c343c63a83597ac33651daf80cb957c9fc78d794a6237fa30

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp313-cp313-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp313-cp313-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp313-cp313-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 36cf6d45e19e1499987b5c54ed45a106d3ba94b0dd7d9da885f4769f9e087f3a
MD5 fc1c13f1de526cc1d1652905297e91bf
BLAKE2b-256 fb741c831e22016e93daeefc8128c11958dd7f666970524573b02a1cf211ca02

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp313-cp313-macosx_11_0_arm64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp313-cp313-macosx_10_13_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp313-cp313-macosx_10_13_x86_64.whl
Algorithm Hash digest
SHA256 d6004661b530040b0d2466274d27d2ac2ac45a5455f09d28c9dfbad0f01fc111
MD5 7d4e56abbe2cf4dd0356893114bf5735
BLAKE2b-256 f3eafb2af5c5fb6f3d4b68b1f96172d8ce2789c3a6dfcb32ed1a4df4b4b72869

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp313-cp313-macosx_10_13_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp312-cp312-win_amd64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp312-cp312-win_amd64.whl
Algorithm Hash digest
SHA256 ebe862a69beede3787f28759f11ff83be83333c1c88995d33cf8c154d3dadf96
MD5 e9c3372d44939468ad7e906f0145b2b4
BLAKE2b-256 c82b446a863e87a78d77d68cada7715e7dc396acc7f6479ecc79cdc118d1e07f

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp312-cp312-win_amd64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp312-cp312-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp312-cp312-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl
Algorithm Hash digest
SHA256 2124242ce2699e663f30214f073e79a444d1654c8599b861618567ea2d3b7ee6
MD5 e2d2fe5091b28f4865eb91f3beb2fc96
BLAKE2b-256 15176f71d2ed4cacc95c6f4761e442f28d83a7584d2fa197d03307c11ee58a33

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp312-cp312-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp312-cp312-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp312-cp312-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 5427de118a6416a7f9148fb5537f27ff27c8b9ca503d680a0f6d3f0c0e030120
MD5 e5943a3fb9db6040f8f116e2313cd10b
BLAKE2b-256 40d1056d2a5a074e002f6b8bff57675c1e9aac1a72203fc8fb50b9ad853e9d9d

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp312-cp312-macosx_11_0_arm64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp312-cp312-macosx_10_13_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp312-cp312-macosx_10_13_x86_64.whl
Algorithm Hash digest
SHA256 12c07f152433cde5d0b8a4225ac9862146a2eeea3e1b411c3621a4a446cf0026
MD5 7bb0836fb2004e9729a1288351377b04
BLAKE2b-256 bac769bcdcd583ab9a600fcc09f33ef183d891da2cfdbe42c24304027217bece

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp312-cp312-macosx_10_13_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp311-cp311-win_amd64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp311-cp311-win_amd64.whl
Algorithm Hash digest
SHA256 40e5062f5f22cc9ce0aa737cdf594d809fc280ea725f7dfafb282df73f1405dd
MD5 10b0949732627e6225ac3dd553695699
BLAKE2b-256 11d1bf2a1f79e09fc67d06aaa102fc3bf267145b53a3f574d0bc1db1a9081232

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp311-cp311-win_amd64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp311-cp311-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp311-cp311-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl
Algorithm Hash digest
SHA256 af75267dd152be97b1aae4ce8334c3006b89f1bfcf2b893ad5ecd11f8df60307
MD5 c01691912b46772318df449a5ca89e85
BLAKE2b-256 2de117e19d216d03a288f8b55bba074a863d1a06058c37f313f5199252379563

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp311-cp311-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp311-cp311-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp311-cp311-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 b62e3f92a6ae6b3fe92a72af34f98968fba8894da31e6146e2da2623618d3bc2
MD5 31747828150e3b44edad88a5003e46e9
BLAKE2b-256 3ae179d02c74eb6b80f658c5662959649a1a59900809eba15d81e20bd4d3b443

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp311-cp311-macosx_11_0_arm64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp311-cp311-macosx_10_9_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp311-cp311-macosx_10_9_x86_64.whl
Algorithm Hash digest
SHA256 377db1bdd854ee827f455aef10bbc9196d72d8a12dd4a1c4eb3c6f735c8d9069
MD5 8108b56f112aa3a6ebea509c3cacc96b
BLAKE2b-256 00bf47d38f984fc700f6ed3124d3e533b8395279b6effb907e56098c2335fe8f

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp311-cp311-macosx_10_9_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp310-cp310-win_amd64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp310-cp310-win_amd64.whl
Algorithm Hash digest
SHA256 5a3c98f647550234c2261ee56ac11e1fd965ee50d0c38df73f16881e48a65549
MD5 0548930b335b2045c0dad30e03421ce7
BLAKE2b-256 37dd283d2613b71213a72341e9f698ee477636c85bcdfc6108a6c90a8713109b

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp310-cp310-win_amd64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp310-cp310-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp310-cp310-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl
Algorithm Hash digest
SHA256 5fd33275c89c54ab332db523fa134294ee869192d61809fac21f7184e95461b1
MD5 04767815c679bc948ee6cbb3b4e36a9e
BLAKE2b-256 b63985f840af5559193e505dcae3ab805b16671cc90a1a82adbc4434d4a328bd

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp310-cp310-manylinux1_x86_64.manylinux2014_x86_64.manylinux_2_17_x86_64.manylinux_2_5_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp310-cp310-macosx_11_0_arm64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp310-cp310-macosx_11_0_arm64.whl
Algorithm Hash digest
SHA256 f5aebbee48a574e53377f5c306be7ec5b265f1612426d8beb2be8a8bcc862e6b
MD5 2ffdc5346a36a3df7ff9515531fc1080
BLAKE2b-256 7e6a00cb0fb7c94d60595469faf3a144c212dbd3c20398a1353131b22a4cd247

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp310-cp310-macosx_11_0_arm64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

File details

Details for the file faust_streaming-0.13.2-cp310-cp310-macosx_10_9_x86_64.whl.

File metadata

File hashes

Hashes for faust_streaming-0.13.2-cp310-cp310-macosx_10_9_x86_64.whl
Algorithm Hash digest
SHA256 0cd663144a95c26caf933355951cc1794ee6e49e474a207191a0331a60681d88
MD5 2a3adfdd7b20864266bc83a0db18e52f
BLAKE2b-256 5b8cd859326518ecef0975a559b7c8e525aff4861c54b0ab74de35f1ab73a55a

See more details on using hashes here.

Provenance

The following attestation bundles were made for faust_streaming-0.13.2-cp310-cp310-macosx_10_9_x86_64.whl:

Publisher: python-package.yml on faust-streaming/faust

Attestations: Values shown here reflect the state when the release was signed and may no longer be current.

Release history Release notifications | RSS feed

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page