DataX SDK for Python

Install

Install the SDK using pip from git:

pip install git+https://github.com/nla-is/[email protected]

Usage

import datax

# initialize
dx = datax.DataX()

while True:
    # receive message
    stream, reference, message = dx.next()
    
    output = process(message)

    # publish message
    dx.emit(output, reference)