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()