View source for Bokeh-Server: Terima TCP Multiline dengan x axis datetime

==ERROR==

Cara ini akan memberikan ERROR

 E-1000 (COLUMN_LENGTHS): ColumnDataSource column lengths are not all the same

Masih belum tahu bagaimana cara mengatasinya


==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()