Install Quix Streams using pip

You'll now install the Quix Streams client library using pip.

You'll need to make sure your system has Python 3.8+ available:

python3 --version

Step 1: Install Quix Streams

To install Quix Streams with pip:

python3 -m pip install quixstreams

Tip

If you already have Quix Streams installed, make sure you are using the latest version with python -m pip install quixstreams -U or python3 -m pip install quixstreams -U, depending on how your system is set up.

Step 2: Create a simple app

You'll now create a simple app to test your installation. You'll connect to a Quix public Kafka broker and consume and print messages.

Create a new file containing the following code:

from quixstreams import Application
import uuid

# Connect to the public Quix hosted broker to consume data
app = Application(
    broker_address="publickafka.quix.io:9092",  # Kafka broker address
    consumer_group=str(uuid.uuid4()),  # Kafka consumer group
    producer_extra_config={'enable.idempotence': False}
)

input_topic = app.topic("demo-onboarding-prod-chat", value_deserializer='json')

sdf = app.dataframe(input_topic)

sdf["tokens_count"] = sdf["message"].apply(lambda message: len(message.split(" ")))
sdf = sdf[["role", "tokens_count"]]

sdf = sdf.update(lambda row: print(row))

app.run(sdf)

Save the code in a file named qs.py.

Step 3: Run the code

Now run the code:

python3 qs.py

You are now consuming data from the demo-onboarding-prod-chat topic and processing it in real time.

You have installed Quix and tested that it's working.

Next steps

Start Building a pipeline!

Start building your first stream processing pipeline locally on the command line with Quix CLI.

Quix CLI Quickstart

Or

Continue learning about Quix Streams

Continue learning how to use Quix Streams library and its capabilities.

Quix Streams Quickstart