Difference between revisions of "Bokeh: Menerima TCP data"

From OnnoWiki
Jump to navigation Jump to search
 
(3 intermediate revisions by the same user not shown)
Line 1: Line 1:
 
Sumber: http://stackoverflow.com/questions/33241229/real-time-bokeh-socket-python/33275677#33275677
 
Sumber: http://stackoverflow.com/questions/33241229/real-time-bokeh-socket-python/33275677#33275677
  
client.py
+
==client.py==
  
 
  import sys
 
  import sys
Line 16: Line 16:
 
   
 
   
 
  try:
 
  try:
     for i in xrange(100):
+
     for i in xrange(100000):
         m = random.random()
+
#    for i in xrange(10):
        message = "%1.4f" % m + "\n"
+
         m0 = random.random()
         print >>sys.stderr, 'sending "%f"' % m
+
#        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)
 
         sock.sendall(message)
         time.sleep(0.01)
+
         time.sleep(0.5)
 
   
 
   
 
  finally:
 
  finally:
Line 29: Line 36:
  
  
server.py
+
 
 +
 
 +
 
 +
 
 +
==server.py==
  
 
  import sys
 
  import sys
 
  import time
 
  import time
 
  import socket
 
  import socket
from pylab import *
+
  from bokeh.plotting import figure, output_server, show, cursession
  from bokeh.plotting import cursession, figure, show, output_server
 
 
   
 
   
  output_server("raw_values")
+
  output_server("raw",url='http://192.168.0.100:5006')
 
   
 
   
 
  # Visualization workflow
 
  # Visualization workflow
 
  counter = 0
 
  counter = 0
 
  rx = [0]
 
  rx = [0]
  ry = [0]
+
  x = [0]
rz = [0]
 
 
  p = figure()
 
  p = figure()
x = [0]
+
  p.line(x, rx, name='raw')
  p.line(x, rx, name='raw_mx')
 
 
   
 
   
 
  # Create a TCP/IP socket
 
  # Create a TCP/IP socket
Line 52: Line 60:
 
   
 
   
 
  # Bind the socket to the port
 
  # Bind the socket to the port
  server_address = ('localhost', 2000)
+
  server_address = ('192.168.0.100', 2000)
 
  print >>sys.stderr, 'starting up on %s port %s' % server_address
 
  print >>sys.stderr, 'starting up on %s port %s' % server_address
 
  sock.bind(server_address)
 
  sock.bind(server_address)
Line 59: Line 67:
 
  sock.listen(1)
 
  sock.listen(1)
 
   
 
   
  renderer = p.select(dict(name="raw_mx"))
+
show(p)
 +
 +
 +
  renderer = p.select(dict(name="raw"))
 
  ds = renderer[0].data_source
 
  ds = renderer[0].data_source
 
   
 
   
  show(p)
+
   
 
   
 
   
 
  while True:
 
  while True:
 
     # Wait for a connection
 
     # Wait for a connection
 
     print >>sys.stderr, 'waiting for a connection'
 
     print >>sys.stderr, 'waiting for a connection'
     connection, client_address = sock.accept()  
+
     connection, client_address = sock.accept()
 
   
 
   
 
     try:
 
     try:
         print >>sys.stderr, 'connection from', client_address  
+
         print >>sys.stderr, 'connection from', client_address
 
   
 
   
 
         while True:
 
         while True:
             data = fromstring(connection.recv(24))
+
             data = connection.recv(20)
 
             print data  
 
             print data  
 
+
            if len(data) == 0:
+
            if len(data) == 0:
 
                 break
 
                 break
 
   
 
   
             rx += [data[0]]
+
             rx += [data]
            ry += [data[1]]
 
            rz += [data[2]]
 
 
             x += [counter]
 
             x += [counter]
             counter += 1  
+
             counter += 1
 
   
 
   
 
             ds.data["x"] = x
 
             ds.data["x"] = x
 
             ds.data["rmag_x"] = rx
 
             ds.data["rmag_x"] = rx
 
             cursession().store_objects(ds)
 
             cursession().store_objects(ds)
 +
 
             time.sleep(0.01)
 
             time.sleep(0.01)
 
   
 
   
Line 93: Line 103:
 
         # Clean up the connection
 
         # Clean up the connection
 
         connection.close()
 
         connection.close()
 
 
 
  
 
==Referensi==
 
==Referensi==
  
 
* http://stackoverflow.com/questions/33241229/real-time-bokeh-socket-python/33275677#33275677
 
* http://stackoverflow.com/questions/33241229/real-time-bokeh-socket-python/33275677#33275677

Latest revision as of 18:53, 28 November 2015

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')

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