1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889 |
- import sys
- import os
- sys.path.append(os.getcwd() + '/..')
- import lib.zchat as chat
- #sys.path.append(os.getcwd() + '/..')
- import time
- data = "hi"
- data = data.encode("utf-8")
- c = chat.Client(port=30002)
- #c = chat.Client()
- client = c
- time.sleep(0.05)
- client.send(data)
- import time
- #while 1:
- # try:
- # data = input("<")
- # data = bytes(data,"utf-8")
- # client.send(data)
- # except Exception as e:
- # print("Exc",e)
- # time.sleep(0.1)
- import memcache
- mc = memcache.Client(['127.0.0.1:11211'], debug=0)
- mc.set("some_key", "Some value")
- value = mc.get("some_key")
- mc.set("another_key", 3)
- mc.delete("another_key")
- import time
- import json
- data = {}
- start = time.time()
- delta = start
- while 1:
- send = 0
- try:
- x=mc.get("10.10.10.13:0")
- except Exception as e:
- print("exc", e)
- time.sleep(1)
- #print(dir(mc))
- #if type(x) is None:
- # mc = memcache.Client(['127.0.0.1:11211'], debug=0)
- # time.sleep(1)
- # print("recon memcache")
- # continue
- if type(x) is list and len(x) == 512:
- ch = 140
- #print(ch,x[ch])
- #data = input("<")
- v = x[ch]
- delta = time.time()-start
- cmd={"iDMX":ch,"iVAL":v,"iT":round(delta,2)} #".format(ch,v)
- cmd = json.dumps([cmd])
- if ch in data:
- if data[ch] != v:
- data[ch] = v
- send = 1
- else:
- data[ch] = cmd
- send = 1
- if send:
- print("+",cmd)
- _data = bytes(cmd,"utf-8")
- client.send(_data)
- else:
- pass
- #print("-",cmd)
- time.sleep(0.01)
|