Star Quix Streams

 Install Quix Streams

 Edit on GitHub

Quix Environment Source

A specialised Kafka Source that simplify copying data from a Quix environment.

How to use the Quix Environment Source

To use a Quix Environment source, you need to create an instance of QuixEnvironmentSource and pass it to the app.dataframe() method.

from quixstreams import Application
from quixstreams.sources import QuixEnvironmentSource

def main():
  app = Application()
  source = QuixEnvironmentSource(
    name="my-source",
    app_config=app.config,
    topic="source-topic",
    quix_sdk_token="quix-sdk-token",
    quix_workspace_id="quix-workspace-id",
  )

  sdf = app.dataframe(source=source)
  sdf.print(metadata=True)

  app.run(sdf)

if __name__ == "__main__":
  main()

Token

The Quix Environment Source requires the sdk token of the source environment. Click here for more information on SDK tokens.