Skip to content


If there's an existing REST API you want to pull data from, you can write a Quix connector that polls the REST API. By way of example, the following code demonstrates the idea:

import quixstreams as qx
import time
import os
import requests
import pandas as pd

client = qx.QuixStreamingClient()

topic_producer = client.get_topic_producer(topic_id_or_name = os.environ["output"])

stream = topic_producer.create_stream() = "Users Stream"

while True:
    response = requests.get("")
    json_response = response.json()
    df = pd.json_normalize(json_response)

The code requests data from the REST API and then publishes it to a stream.