请教 Python 的 producer-consumer 模型与数据库操作问题

最近在学习生产者消费者模型，假如有如下需求：从某个网址读取 log ，提取出用户 id 然后发送邮件。在不涉及数据库操作的情况下，下面的示例代码（打不开 gist 只能贴在这里了。。）可以运行。

但现在问题来了，如果需要将每一次读取的 log 内容和发送记录都存储在数据库里，保证同一个 id 只收到一次，这个数据库操作应该放在哪个线程里面呢？ 用的是 kennethreitz 大神的 records + Python 自带的 Sqlite3 ，尝试了在 2 个 Thread __init__ 的时候分别连接同一个数据库文件，但是提示在一个线程内创建的连接不能在另一个线程内使用，这里有些迷惑。 Or 这个需求可以用另外的原理完成？

import threading import time import Queue Q = Queue.Queue() class ProducerThread(threading.Thread): def __init__(self, out_q): threading.Thread.__init__(self, name='Producer') self.q = out_q def run(self): while True: # 这里读取 log log = getlog() if log: for each in log: self.q.put(each) else: print('NO MORE LOG') time.sleep(60) class ConsumerThread(threading.Thread): def __init__(self, out_q): threading.Thread.__init__(self, name='Consumer') self.q = out_q def run(self): while True: # consume the data. chunk = self.q.get() print(u'开始发送...{0}'.format(chunk)) time.sleep(2) # 模拟发送 self.q.task_done() def main(): t = ProducerThread(Q) t.start() c = ConsumerThread(Q) c.start() Q.join() if __name__ == "__main__": main()