Untitled

import sys

import avro.ipc as ipc
import avro.protocol as protocol

PROTOCOL = protocol.parse(open("flume.avpr").read())

server_addr = ('172.28.19.112', 41414)

class UsageError(Exception):
    def __init__(self, value):
        self.value = value
    def __str__(self):
        return repr(self.value)

if __name__ == '__main__':
    if len(sys.argv) != 3:
        raise UsageError("Usage: <category> <body>")

    print("Connecting to " + str(server_addr[0]) + ", " + str(server_addr[1]))
    client = ipc.HTTPTransceiver(server_addr[0], server_addr[1])
    requestor = ipc.Requestor(PROTOCOL, client)

    # fill in the Message record and send it
    event = dict()
    event['headers'] = dict()
    event['headers']['category'] = sys.argv[1]
    event['body'] = sys.argv[2]

    params = dict()
    params['event'] = event
    requestor.request('append', params)
    #print("Result: " + requestor.request('append', params)))
    print("done")

    # cleanup
    client.close()