Difference between revisions of "Bokeh-Server: Terima UDP dengan x axis datetime"
Jump to navigation
Jump to search
Onnowpurbo (talk | contribs) |
Onnowpurbo (talk | contribs) |
||
Line 1: | Line 1: | ||
==client.py== | ==client.py== | ||
+ | |||
+ | python script untuk testing server bokeh | ||
+ | |||
import sys | import sys | ||
Line 24: | Line 27: | ||
print >>sys.stderr, 'closing socket' | print >>sys.stderr, 'closing socket' | ||
sock.close() | sock.close() | ||
+ | |||
+ | ==Arduino Program== | ||
+ | |||
+ | /* | ||
+ | UDPSendAnalogInput: | ||
+ | |||
+ | created 27 Nov 2015 | ||
+ | by Onno W. Purbo | ||
+ | |||
+ | This code is in the public domain. | ||
+ | */ | ||
+ | |||
+ | #include <SPI.h> // needed for Arduino versions later than 0018 | ||
+ | #include <Ethernet.h> | ||
+ | #include <EthernetUdp.h> // UDP library from: bjoern@cs.stanford.edu 12/30/2008 | ||
+ | |||
+ | // Enter a MAC address and IP address for your controller below. | ||
+ | // The IP address will be dependent on your local network: | ||
+ | byte mac[] = { | ||
+ | 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED | ||
+ | }; | ||
+ | IPAddress ip(192, 168, 0, 3); | ||
+ | unsigned int localPort = 8888; // local port to listen on | ||
+ | |||
+ | // An EthernetUDP instance to let us send and receive packets over UDP | ||
+ | EthernetUDP Udp; | ||
+ | IPAddress remoteIP(192,168,0,100); | ||
+ | unsigned int remotePort = 8888; | ||
+ | |||
+ | void setup() { | ||
+ | // start the Ethernet and UDP: | ||
+ | Ethernet.begin(mac, ip); | ||
+ | Udp.begin(localPort); | ||
+ | Serial.begin(9600); | ||
+ | } | ||
+ | |||
+ | void loop() { | ||
+ | Udp.beginPacket(remoteIP, remotePort); | ||
+ | int sensorReading = analogRead(0); | ||
+ | Udp.print(sensorReading); | ||
+ | Udp.write("\n"); | ||
+ | Serial.println(sensorReading); | ||
+ | Udp.endPacket(); | ||
+ | delay(1000); | ||
+ | } | ||
==Server== | ==Server== |
Revision as of 10:24, 3 January 2016
client.py
python script untuk testing server bokeh
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', 8888) sock.connect(server_address) try: for i in xrange(100000): m0 = random.random() message = "%1.4f" % m0 print >>sys.stderr, 'sending ' , message sock.sendall(message) time.sleep(0.5) finally: print >>sys.stderr, 'closing socket' sock.close()
Arduino Program
/* UDPSendAnalogInput: created 27 Nov 2015 by Onno W. Purbo This code is in the public domain. */ #include <SPI.h> // needed for Arduino versions later than 0018 #include <Ethernet.h> #include <EthernetUdp.h> // UDP library from: bjoern@cs.stanford.edu 12/30/2008 // Enter a MAC address and IP address for your controller below. // The IP address will be dependent on your local network: byte mac[] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xFE, 0xED }; IPAddress ip(192, 168, 0, 3); unsigned int localPort = 8888; // local port to listen on // An EthernetUDP instance to let us send and receive packets over UDP EthernetUDP Udp; IPAddress remoteIP(192,168,0,100); unsigned int remotePort = 8888; void setup() { // start the Ethernet and UDP: Ethernet.begin(mac, ip); Udp.begin(localPort); Serial.begin(9600); } void loop() { Udp.beginPacket(remoteIP, remotePort); int sensorReading = analogRead(0); Udp.print(sensorReading); Udp.write("\n"); Serial.println(sensorReading); Udp.endPacket(); delay(1000); }
Server
bokeh-server --ip 192.168.0.100
Akan keluar
Bokeh Server Configuration ========================== python version : 2.7.11 bokeh version : 0.10.0 listening : 192.168.0.100:5006 backend : memory python options : debug:OFF, verbose:OFF, filter-logs:OFF, multi-user:OFF js options : debugjs:OFF
udp-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 rx = [0] x = [0] n = datetime.datetime.now() x = ['%d.%d'%(n.minute*60+n.second,n.microsecond)] 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_DGRAM) # Bind the socket to the port server_address = ('192.168.0.100', 8888) print >>sys.stderr, 'starting up on %s port %s' % server_address sock.bind(server_address) show(p) renderer = p.select(dict(name="raw")) ds = renderer[0].data_source while True: data, addr = sock.recvfrom(1024) # buffer size is 1024 bytes print data if len(data) == 0: break rx += [data] n = datetime.datetime.now() x += ['%d.%d'%(n.minute*60+n.second,n.microsecond)] ds.data["x"] = x ds.data["rmag_x"] = rx cursession().store_objects(ds) time.sleep(0.01)
Jalankan
python udp-server.py