From 0fc699073e89209fbb6bf1345cb562601760fbe6 Mon Sep 17 00:00:00 2001 From: "Matthias P. Braendli" Date: Sat, 1 Aug 2015 15:38:04 +0200 Subject: Add simple zmq remote python script --- doc/zmq-ctrl/zmq_remote.py | 42 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100755 doc/zmq-ctrl/zmq_remote.py diff --git a/doc/zmq-ctrl/zmq_remote.py b/doc/zmq-ctrl/zmq_remote.py new file mode 100755 index 0000000..dffe53e --- /dev/null +++ b/doc/zmq-ctrl/zmq_remote.py @@ -0,0 +1,42 @@ +#!/usr/bin/env python2 + +import sys +import zmq + +context = zmq.Context() + +sock = context.socket(zmq.REQ) + +if len(sys.argv) < 2: + print("Usage: program url cmd [args...]") + sys.exit(1) + +sock.connect(sys.argv[1]) + +message_parts = sys.argv[2:] + +# first do a ping test + +print("ping") +sock.send("ping") +data = sock.recv_multipart() +print("Received: {}".format(len(data))) +for i,part in enumerate(data): + print(" {}".format(part)) + +for i, part in enumerate(message_parts): + if i == len(message_parts) - 1: + f = 0 + else: + f = zmq.SNDMORE + + print("Send {}({}): '{}'".format(i, f, part)) + + sock.send(part, flags=f) + +data = sock.recv_multipart() + +print("Received: {}".format(len(data))) +for i,part in enumerate(data): + print(" RX {}: {}".format(i, part)) + -- cgit v1.2.3