Difference between revisions of "Bokeh-Server: Terima TCP dengan x axis datetime"
Jump to navigation
Jump to search
Onnowpurbo (talk | contribs) |
Onnowpurbo (talk | contribs) |
||
(One intermediate revision by the same user not shown) | |||
Line 15: | Line 15: | ||
try: | try: | ||
for i in xrange(100000): | for i in xrange(100000): | ||
− | |||
m0 = random.random() | m0 = random.random() | ||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
message = "%1.4f" % m0 | message = "%1.4f" % m0 | ||
print >>sys.stderr, 'sending ' , message | print >>sys.stderr, 'sending ' , message | ||
Line 31: | Line 24: | ||
print >>sys.stderr, 'closing socket' | print >>sys.stderr, 'closing socket' | ||
sock.close() | sock.close() | ||
+ | |||
+ | ==Server== | ||
+ | |||
+ | bokeh-server --ip 192.168.0.100 | ||
Line 44: | Line 41: | ||
# Visualization workflow | # Visualization workflow | ||
− | |||
rx = [0] | rx = [0] | ||
x = [0] | x = [0] | ||
+ | n = datetime.datetime.now() | ||
+ | x = ['%d.%d'%(n.minute*60+n.second,n.microsecond)] | ||
p = figure(x_axis_type="datetime") | p = figure(x_axis_type="datetime") | ||
p.line(x, rx, name='raw') | p.line(x, rx, name='raw') | ||
Line 59: | Line 57: | ||
# Listen for incoming connections | # Listen for incoming connections | ||
− | sock.listen(1) | + | sock.listen(1) |
show(p) | show(p) | ||
Line 65: | Line 63: | ||
renderer = p.select(dict(name="raw")) | renderer = p.select(dict(name="raw")) | ||
ds = renderer[0].data_source | ds = renderer[0].data_source | ||
− | |||
while True: | while True: | ||
# Wait for a connection | # Wait for a connection | ||
print >>sys.stderr, 'waiting for a connection' | print >>sys.stderr, 'waiting for a connection' | ||
− | connection, client_address = sock.accept() | + | connection, client_address = sock.accept() |
try: | try: | ||
− | print >>sys.stderr, 'connection from', client_address | + | print >>sys.stderr, 'connection from', client_address |
while True: | while True: | ||
data = connection.recv(20) | data = connection.recv(20) | ||
− | print data | + | print data |
if len(data) == 0: | if len(data) == 0: | ||
Line 83: | Line 80: | ||
rx += [data] | rx += [data] | ||
− | + | n = datetime.datetime.now() | |
+ | x += ['%d.%d'%(n.minute*60+n.second,n.microsecond)] | ||
ds.data["x"] = x | ds.data["x"] = x |
Latest revision as of 10:09, 30 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): m0 = random.random() 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
bokeh-server --ip 192.168.0.100
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 rx = [0] x = [0] n = datetime.datetime.now() x = ['%d.%d'%(n.minute*60+n.second,n.microsecond)] 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] n = datetime.datetime.now() x += ['%d.%d'%(n.minute*60+n.second,n.microsecond)] ds.data["x"] = x ds.data["rmag_x"] = rx cursession().store_objects(ds) time.sleep(0.01) finally: # Clean up the connection connection.close()