Bokeh: Menerima TCP data

Sumber: http://stackoverflow.com/questions/33241229/real-time-bokeh-socket-python/33275677#33275677

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 socket from bokeh.plotting import figure, output_server, show, cursession

output_server("raw",url='http://192.168.0.100:5006')

1. Visualization workflow

counter = 0 rx = [0] x = [0] p = figure() p.line(x, rx, name='raw')

1. Create a TCP/IP socket

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

1. 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)

1. 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 += [counter]
           counter += 1

           ds.data["x"] = x
           ds.data["rmag_x"] = rx
           cursession().store_objects(ds)

           time.sleep(0.01)

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

Referensi

• http://stackoverflow.com/questions/33241229/real-time-bokeh-socket-python/33275677#33275677