diff options
| author | Tim Redfern <tim@eclectronics.org> | 2012-06-30 09:58:06 +0100 |
|---|---|---|
| committer | Tim Redfern <tim@eclectronics.org> | 2012-06-30 09:58:06 +0100 |
| commit | 4525c22d902e1eff47d6a8a64d022d885ac3a76a (patch) | |
| tree | 4601b215e8590030e5644848df9db6f7d0a46a12 /eventStreamer | |
| parent | afed229f7f70d51313239394f6e1079fa6086da3 (diff) | |
version 1.0
Diffstat (limited to 'eventStreamer')
| -rwxr-xr-x | eventStreamer/eventStreamer.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/eventStreamer/eventStreamer.py b/eventStreamer/eventStreamer.py index d35bcd8..35c7033 100755 --- a/eventStreamer/eventStreamer.py +++ b/eventStreamer/eventStreamer.py @@ -28,6 +28,9 @@ def sendevent(e): #send all data in each event to avoid translation script having a state print str(e[3]),devices[e[3]]['IMSI'],devices[e[3]]['IMEI'],devices[e[3]]['number'],str(e[1]) outsock.sendto( devices[e[3]]['IMSI']+"^"+devices[e[3]]['IMEI']+"^"+devices[e[3]]['number']+"^"+str(e[1]), (config.viz_ip, config.viz_port) ) + +def senddevice(d): + outsock.sendto( d['IMSI']+"^"+d['IMEI']+"^"+d['number']+"^"+"retreived", (config.viz_ip, config.viz_port) ) def main(): @@ -64,6 +67,7 @@ def main(): d['IMEI']=row[2] d['number']=row[3] devices[row[0]]=d + senddevice(d) except: print "Error: unable to fetch handset list" |