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(100):
        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"
        print >>sys.stderr, 'sending ' , message
        sock.sendall(message)
        time.sleep(0.01)

finally:
    print >>sys.stderr, 'closing socket'
    sock.close()

server.py

import sys
import time
import socket
from pylab import *
from bokeh.plotting import cursession, figure, show, output_server

output_server("raw_values")

# Visualization workflow
counter = 0
rx = [0]
ry = [0]
rz = [0]
p = figure()
x = [0]
p.line(x, rx, name='raw_mx')

# Create a TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# Bind the socket to the port
server_address = ('localhost', 2000)
print >>sys.stderr, 'starting up on %s port %s' % server_address
sock.bind(server_address)

# Listen for incoming connections
sock.listen(1)

renderer = p.select(dict(name="raw_mx"))
ds = renderer[0].data_source

show(p)

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 = fromstring(connection.recv(24))
            print data 

           if len(data) == 0:
               break

            rx += [data[0]]
            ry += [data[1]]
            rz += [data[2]]
            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