Bokeh-Server: Terima TCP Multiline dengan x axis datetime

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(100):
        m0 = random.random()
        m1 = random.random()
        message = "%1.4f" % m0  + " %1.4f" % m1
        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
ana1 = [0]
ana2 = [0]
x = [0]
n = datetime.datetime.now()
x = ['%d.%d'%(n.minute*60+n.second,n.microsecond)]
p = figure(x_axis_type="datetime")
p.multi_line([x, ana1],[x, ana2], color=["firebrick","navy"],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).split()
            ana1 += data[0]
            ana2 += data[1]

            if len(data) == 0:
               break

            n  = datetime.datetime.now()
            x  += ['%d.%d' %(n.minute*60+n.second,n.microsecond)]

            ds.data["x"] = x
            ds.data["ana1"] = ana1
            ds.data["ana2"] = ana2
            cursession().store_objects(ds)
            time.sleep(0.01)

    finally:
        # Clean up the connection
        connection.close()