TypeStream is an open-source streaming platform that allows you to write, run, and ship typed data pipelines with a minimal, familiar syntax in a matter of minutes.
See how TypeStream radically speeds up your streaming applications development 👇
No matter how simple your data pipeline, you need to write an app, test it exhaustively. You also have manage its deployment in the cloud. This process always takes days, often weeks.
Fire up a TypeStream shell session to quickly iterate your transformations locally. Once you're ready, ship them to production with one simple command. Minutes, not days.
Replace whole applications with one-liners!
Say we have a log of page views and we want to build a heatmap of where people are visiting from. We can enrich those page views with the country by making a `GET` call to an external API:
cat dev/kafka/local/topics/page_views | enrich { view -> http "https://api.country.is/#{$view.ip_address}" | cut .country}
Let's say you have a stream of page views of your site being logged to a "page_views" topic. We can remove plunk the data we want and re-emit the data:
cat dev/kafka/local/topics/page_views | cut .book_id .viewed_at
Say we have a bookstore and we record all new books to the topic "books". We would like to enrich the book information with summaries from OpenAI:
cat dev/kafka/local/topics/books | enrich { book -> openai-complete "Summarize the book #{$book.title}" | cut .text}
Join our wait list and we'll reach out as soon as possible!