我有一个使用“线程”模块的Python程序。每秒一次,我的程序启动一个新线程,该线程从Web上获取一些数据,并将这些数据存储到我的硬盘中。我想使用sqlite3来存储这些结果,但是我无法使其正常工作。问题似乎与以下几行有关:
conn = sqlite3.connect("mydatabase.db")
以前,我将所有结果存储在CSV文件中,并且没有任何这些文件锁定问题。希望使用sqlite可以实现。有任何想法吗?
您可以使用消费者- 生产者模式。例如,您可以创建线程之间共享的队列。从Web上获取数据的第一个线程将该数据排队在共享队列中。拥有数据库连接的另一个线程使队列中的数据出队,并将其传递给数据库。