15 skills found
faust-streaming / FaustPython Stream Processing. A Faust fork
marcosschroh / Dataclasses AvroschemaGenerate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserialize python instances with avro schemas.
DBraun / TD FaustFAUST (Functional Audio Stream) for TouchDesigner
wayfair-incubator / DaggerA simple Python-based distributed workflow engine
lucretiomsp / PhaustoUse the Faust (Functional Audio Stream) functional programming language for sound synthesis inside Pharo
faust-streaming / Python RocksdbPython bindings for RocksDB used by faust-streaming
Leem0sh / FKRExample of event-driven architecture with FastAPI Gateway, Kafka, Redis pub/sub and Faust-streaming
d3vzer0 / StreamioFaust Streaming engine for simple keyword domain monitoring
ggbong734 / Udacity Data StreamingAn event streaming pipeline built using Kafka, KSQL, Faust, and Spark Structured Streaming
lsst-sqre / Kafka AggregatorA Kafka aggregator based on the Faust Python Stream Processing library
grillazz / Fastapi FaustSimple integration of FastAPI with Faust Python Stream Processing Fork
youheekil / Udacity Data StreamingProjects completed in the Udacity Data Streaming Nanodegree program. Tech used: Apache Kafka, Kafka Connect, KSQL, Faust Stream Processing, Spark Structured Streaming
Zak-Musah / Apache Kafka Data Pipeline In AWSA data streaming pipeline built with Apache Kafka and Faust to perform automatic word counting of scientific files dropped in AWS S3 bucket
dinaAbdelrahman / DataStreaming.P1.Optimize Public TransportStreaming data project (topic definition, creation of producers and consumers), tools: Kafka, Kafka connect, Ksql, Faust, Rest API
judeleonard / Kafka Streaming PipelineThe goal of this project is aimed at optimizing Bank Marketing Model through building an event streaming pipeline around Apache Kafka and its ecosystem that communicates with a Machine learning model microservice. Utilizing this to display the likelihood and status of Bank Customers in real time.