| rdudyala | b086cf3 | 2016-08-11 00:07:45 -0400 | [diff] [blame] | 1 | import socket |
| 2 | import msgpack |
| 3 | from oslo_utils import units |
| 4 | import logging |
| 5 | UDP_IP = "10.11.10.1" |
| 6 | UDP_PORT = 5006 |
| 7 | |
| 8 | logging.basicConfig(format='%(asctime)s %(filename)s %(levelname)s %(message)s',filename='udp_client.log',level=logging.INFO) |
| 9 | udp = socket.socket(socket.AF_INET, # Internet |
| 10 | socket.SOCK_DGRAM) # UDP |
| 11 | udp.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) |
| 12 | udp.bind((UDP_IP, UDP_PORT)) |
| 13 | while True: |
| 14 | data, source = udp.recvfrom(64 * units.Ki) |
| 15 | #print data |
| 16 | #try: |
| 17 | sample = msgpack.loads(data, encoding='utf-8') |
| 18 | logging.info("%s",sample) |
| 19 | print sample |
| 20 | #except Exception: |
| 21 | #logging.info("%s",sample) |
| 22 | # print ("UDP: Cannot decode data sent by %s"), source |