Difference between revisions of "Bokeh-Server: Terima TCP dengan x axis datetime"

From OnnoWiki
Jump to navigation Jump to search
(New page: ==client.py== ==server.py==)
 
Line 1: Line 1:
 
==client.py==
 
==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==
  
==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
 +
counter = 0
 +
rx = [0]
 +
x = [0]
 +
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]
 +
            x += [datetime.datetime.now()]
 +
 +
            ds.data["x"] = x
 +
            ds.data["rmag_x"] = rx
 +
            cursession().store_objects(ds)
 +
 +
            time.sleep(0.01)
 +
 +
    finally:
 +
        # Clean up the connection
 +
        connection.close()

Revision as of 18:39, 28 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):
#     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 datetime
import socket
from bokeh.plotting import figure, output_server, show, cursession

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

# Visualization workflow
counter = 0
rx = [0]
x = [0]
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]
            x += [datetime.datetime.now()]

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

            time.sleep(0.01)

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