Streaming data via OPeNDAP

gistfile1.py

from pydap.model import *
from pydap.handlers.lib import IterData, BaseHandler


class SensorData(IterData):                                                     
    """                                                                         
    Sensor data as a structured array like object.                              
                                                                                
    """                                                                         
    def gen(self):                                                              
        while 1:                                                                
            timestamp = time.time()                                             
            temperature, voltage = get_temperature()                            
            yield timestamp, voltage, temperature                               
            time.sleep(0.1)                                                     


dataset = DatasetType('roberrypi')                                          
seq = dataset['sensor'] = SequenceType('sensor')                            
seq['time'] = BaseType('time', units='seconds since 1970-01-01')            
seq['voltage'] = BaseType('voltage', units='mV')                            
seq['temperature'] = BaseType('temperature', units='deg C')                 
seq.data = SensorData('sensor', seq.keys())                                 

                                                                                                                                                                
if __name__ == '__main__': 
    app = BaseHandler(dataset)                                                  
    from werkzeug.serving import run_simple                                     
    run_simple('0.0.0.0', 8080, app, use_reloader=True, threaded=True)