Test Stream.to_mqtt

test.py

import time

from streamz import Stream


def run():
    source = Stream.from_mqtt(
        "localhost",
        1883,
        "topic/logpipe_in",
    )

    output = Stream.to_mqtt(
        "localhost",
        1883,
        "topic/logpipe_out",
    )

    source.sink(output)

    source.start()

    while True:
        time.sleep(5)


if __name__ == "__main__":
    run()