Download remote data transmision system - Worcester Polytechnic Institute

buf.write( "%s\n" % readings[0].getPhoneNumber() )
buf.write( "timestamp," )
col_names = string.join( readings[0].getColumnNames(), ',' )
buf.write( "%s\n" % col_names )
buf.write( "[DATA]\n" )
for reading in readings:
buf.write( "%s\n" % reading.toString() )
timestamp = datetime.datetime.now()
subject = "version=\"%s\",timestamp=\"%s\"" % \
( MESSAGE_FORMAT_VERSION,
timestamp )
logging.debug( "%s: posting message subject = \"%s\"",
__FUNCTION__, subject )
self.newsPoster.setSubject( subject )
self.newsPoster.postText( buf.getvalue() )
# break
# one shot
logging.debug( "%s: exiting", __FUNCTION__ )
if __name__ == '__main__':
setupLogging()
logging.debug( "%s: starting", __name__ )
Receive( sys.argv ).run()
sys.exit( 0 )
Store
#!/usr/bin/env python
import
import
import
import
import
import
import
logging
sys
StringIO
string
datetime
pg
re
import sri.ayoung.DatetimeUtils
from Transport import ProcessClient
from Transport import NewsPollMixin
import Reading
import Datalogger
dbname = "datalogger"
user = "transport"
class Store( ProcessClient, NewsPollMixin ):
106