| import logging |
|
| logging.basicConfig(level=logging.DEBUG, |
|
| format='%(asctime)s\t%(levelname)s\t%(message)s') |
|
| |
|
| import snd |
import snd |
| import time |
import time |
| from datetime import date |
from datetime import date |
| import threading |
import threading |
| from pydispatch import dispatcher |
from pydispatch import dispatcher |
| import wave |
import wave |
| |
import psycopg2 |
| |
import sys,os |
| |
|
| |
|
| |
sys.path.insert(0, os.path.join(os.path.dirname(__file__) or '.', 'pynma')) |
| |
import pynma |
| |
|
| filename = "demo.wav" |
filename = "demo.wav" |
| MIN_LENGTH = 90000 |
nma = pynma.PyNMA( "apikey(s)", "developerkey") |
| |
conn = psycopg2.connect("dbname=test user=postgres") |
| |
|
| def worker(filename): |
def worker(filename): |
| |
|
| """thread worker function |
"""thread worker function |
| http://www.doughellmann.com/PyMOTW/threading/ |
http://www.doughellmann.com/PyMOTW/threading/ |
| |
|
| https://github.com/uskr/pynma |
https://github.com/uskr/pynma |
| ffmpeg -i 2012-09-29-1348911268.34-demo.wav -ar 8000 -ab 4.75k test.3gp |
|
| http://stackoverflow.com/questions/2559746/getting-error-while-converting-wav-to-amr-using-ffmpeg |
http://stackoverflow.com/questions/1092531/event-system-in-python """ |
| """ |
|
| print 'Worker for '+filename |
print 'Worker for '+filename |
| |
"""nma.push(application, event, description, (opt) url,)""" |
| |
"""http://initd.org/psycopg/docs/usage.html""" |
| |
#cur = conn.cursor() |
| |
#cur.execute("INSERT INTO test (num, data) VALUES (%s, %s)",(100, "abc'def")) |
| |
#conn.commit() |
| |
#cur.close() |
| |
|
| return |
return |
| |
|
| def filenameMaker(): |
def filenameMaker(): |
| global filename |
global filename |
| filename = date.today().isoformat()+'-'+str(time.time())+'-demo.wav' |
filename = date.today().isoformat()+'-'+str(time.time())+'-demo.wav' |
| |
|
| def record_to_async_file(): |
def record_to_async_file(): |
| "Records from the microphone and outputs the resulting data to `path`" |
"Records from the microphone and outputs the resulting data to `path`" |
| sample_width, data = snd.record() |
sample_width, data = snd.record() |
| print str(len(data)) |
data = snd.pack('<' + ('h'*len(data)), *data) |
| if len(data) > MIN_LENGTH: |
path = filename |
| data = snd.pack('<' + ('h'*len(data)), *data) |
dispatcher.send( signal='FILE_CREATED', sender=filename, filename=filename) |
| path = filename |
wf = wave.open(path, 'wb') |
| dispatcher.send( signal='FILE_CREATED', sender=filename, filename=filename) |
wf.setnchannels(1) |
| wf = wave.open(path, 'wb') |
wf.setsampwidth(sample_width) |
| wf.setnchannels(1) |
wf.setframerate(snd.RATE) |
| wf.setsampwidth(sample_width) |
wf.writeframes(data) |
| wf.setframerate(snd.RATE) |
wf.close() |
| wf.writeframes(data) |
print("done - result written to "+path) |
| wf.close() |
|
| print("done - result "+str(len(data))+" frames written to "+path) |
|
| |
|
| dispatcher.connect( filenameMaker, signal='SND_STARTED', sender=dispatcher.Any ) |
dispatcher.connect( filenameMaker, signal='SND_STARTED', sender=dispatcher.Any ) |
| dispatcher.connect( worker, signal='FILE_CREATED', sender=dispatcher.Any ) |
dispatcher.connect( worker, signal='FILE_CREATED', sender=dispatcher.Any ) |
| print "Scannr started..." |
print "Scannr started..." |
| while True: |
while True: |
| print "ready to record" |
print "ready to record" |
| record_to_async_file() |
record_to_async_file() |
| |
|