Providing quality software engineering content in the form of tutorials, applications, services, and commentary suited for developers.
In this article I present an example of how one can use Kafka and the Confluent ksqlDB stream processing database to process a simplified dataset of fake stock quotes. The ultimate goal of this excercise will be to user ksqlDB to inspect a stream of stock quotes for individual companies in 1 minute windows and identify when a window has introduced a new daily high or low stock price.
PyFlink is the Python API for Apache Flink which allows you to develop batch and stream data processing pipelines on modern distributed computing architectures.
In this article I go over how to use Apache Flink Table API in Python to consume data from and write data to a Confluent Community Platform Apache Kafka Cluster running locally in Docker.
In this article I demonstrate how to use Python to perform rudimentary topic modeling and identification with the help of the GENSIM and Natural Language Toolkit (NLTK) libraries.
In this article I demonstrate the power of the Python based Click package for building beautiful Command Line Interface (CLI) programs by creating a clone of the popular wc Unix command.
In this short "How To" article I demonstrate implementing a Python based Command Line Interface (CLI) application using the Click package to consume text input from both files and standard input streams.
By