Difference between revisions of "Bokeh-Server: Terima TCP dengan x axis datetime"
Jump to navigation
Jump to search
Onnowpurbo (talk | contribs) (New page: ==client.py== ==server.py==) |
Onnowpurbo (talk | contribs) |
||
Line 1: | Line 1: | ||
==client.py== | ==client.py== | ||
+ | import sys | ||
+ | import time | ||
+ | import socket | ||
+ | import random | ||
+ | |||
+ | # Create a TCP/IP socket | ||
+ | sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) | ||
+ | |||
+ | # Connect the socket to the port where the server is listening | ||
+ | server_address = ('192.168.0.100', 2000) | ||
+ | sock.connect(server_address) | ||
+ | |||
+ | try: | ||
+ | for i in xrange(100000): | ||
+ | # for i in xrange(10): | ||
+ | m0 = random.random() | ||
+ | # m1 = random.random() | ||
+ | # m2 = random.random() | ||
+ | # m3 = random.random() | ||
+ | # m4 = random.random() | ||
+ | # m5 = random.random() | ||
+ | # message = "%1.4f" % m1 + " %1.4f" % m2 + " %1.4f" % m3 + " %1.4f" % m4 + " %1.4f" % m5 + "\n" | ||
+ | message = "%1.4f" % m0 | ||
+ | print >>sys.stderr, 'sending ' , message | ||
+ | sock.sendall(message) | ||
+ | time.sleep(0.5) | ||
+ | |||
+ | finally: | ||
+ | print >>sys.stderr, 'closing socket' | ||
+ | sock.close() | ||
+ | ==server.py== | ||
− | == | + | import sys |
+ | import time | ||
+ | import datetime | ||
+ | import socket | ||
+ | from bokeh.plotting import figure, output_server, show, cursession | ||
+ | |||
+ | output_server("raw",url='http://192.168.0.100:5006') | ||
+ | |||
+ | # Visualization workflow | ||
+ | counter = 0 | ||
+ | rx = [0] | ||
+ | x = [0] | ||
+ | p = figure(x_axis_type="datetime") | ||
+ | p.line(x, rx, name='raw') | ||
+ | |||
+ | # Create a TCP/IP socket | ||
+ | sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) | ||
+ | |||
+ | # Bind the socket to the port | ||
+ | server_address = ('192.168.0.100', 2000) | ||
+ | print >>sys.stderr, 'starting up on %s port %s' % server_address | ||
+ | sock.bind(server_address) | ||
+ | |||
+ | # Listen for incoming connections | ||
+ | sock.listen(1) | ||
+ | |||
+ | show(p) | ||
+ | |||
+ | renderer = p.select(dict(name="raw")) | ||
+ | ds = renderer[0].data_source | ||
+ | |||
+ | |||
+ | while True: | ||
+ | # Wait for a connection | ||
+ | print >>sys.stderr, 'waiting for a connection' | ||
+ | connection, client_address = sock.accept() | ||
+ | |||
+ | try: | ||
+ | print >>sys.stderr, 'connection from', client_address | ||
+ | |||
+ | while True: | ||
+ | data = connection.recv(20) | ||
+ | print data | ||
+ | |||
+ | if len(data) == 0: | ||
+ | break | ||
+ | |||
+ | rx += [data] | ||
+ | x += [datetime.datetime.now()] | ||
+ | |||
+ | ds.data["x"] = x | ||
+ | ds.data["rmag_x"] = rx | ||
+ | cursession().store_objects(ds) | ||
+ | |||
+ | time.sleep(0.01) | ||
+ | |||
+ | finally: | ||
+ | # Clean up the connection | ||
+ | connection.close() |
Revision as of 18:39, 28 November 2015
client.py
import sys import time import socket import random # Create a TCP/IP socket sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # Connect the socket to the port where the server is listening server_address = ('192.168.0.100', 2000) sock.connect(server_address) try: for i in xrange(100000): # for i in xrange(10): m0 = random.random() # m1 = random.random() # m2 = random.random() # m3 = random.random() # m4 = random.random() # m5 = random.random() # message = "%1.4f" % m1 + " %1.4f" % m2 + " %1.4f" % m3 + " %1.4f" % m4 + " %1.4f" % m5 + "\n" message = "%1.4f" % m0 print >>sys.stderr, 'sending ' , message sock.sendall(message) time.sleep(0.5) finally: print >>sys.stderr, 'closing socket' sock.close()
server.py
import sys import time import datetime import socket from bokeh.plotting import figure, output_server, show, cursession output_server("raw",url='http://192.168.0.100:5006') # Visualization workflow counter = 0 rx = [0] x = [0] p = figure(x_axis_type="datetime") p.line(x, rx, name='raw') # Create a TCP/IP socket sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # Bind the socket to the port server_address = ('192.168.0.100', 2000) print >>sys.stderr, 'starting up on %s port %s' % server_address sock.bind(server_address) # Listen for incoming connections sock.listen(1) show(p) renderer = p.select(dict(name="raw")) ds = renderer[0].data_source while True: # Wait for a connection print >>sys.stderr, 'waiting for a connection' connection, client_address = sock.accept() try: print >>sys.stderr, 'connection from', client_address while True: data = connection.recv(20) print data if len(data) == 0: break rx += [data] x += [datetime.datetime.now()] ds.data["x"] = x ds.data["rmag_x"] = rx cursession().store_objects(ds) time.sleep(0.01) finally: # Clean up the connection connection.close()