sqlite3.OperationalError: database is lockedの解決方法

Question

ラズパイに接続したタクトスイッチを押すと、その履歴をsqliteに保存しつつ、押された回数をカウントして、
htmlでwebブラウザに値を返すようなプログラムを考えております。
下記サイトを参考にしております。
https://reerishun.com/makerblog/?p=653

下記コードを考えました。

# table writer

def table_wrt():

    def _count(hoge):
        if GPIO.input(17):
            global count
            count += 1
            print(str(count) + "回目")
            time.sleep(0.2)

    @app.route("/")
    def index():
        print(str(os.getpid()) + ": index(): count=" + str(count))
        return render_template("index1.html", testcount = count)

    GPIO.add_event_detect(17, GPIO.BOTH, callback=_count, bouncetime=1000)
    time.sleep(0.2)

    # connect DB
    conn = sqlite3.connect('pushswitch.db')
    c = conn.cursor()

    # count variable
    i = 0


    # create table
    c.execute('select count(*) from sqlite_master where type="table" and name="data"')
    if c.fetchone() == (0,):
        c.execute('create table data(time text)')


    try:
        while True:
            if GPIO.input(17) == 1:
                while GPIO.input(17) == 1:
                   continue
                # get date and time
                dt_now = datetime.datetime.now()

                sql = 'insert into data values (?)'
                params = (dt_now.strftime('%Y/%m/%d %H:%M:%S'),)
                

                # insert table
                c.execute(sql, params)
                i += 1
                print("pushed:", i, "time")


    except KeyboardInterrupt:
        # data commit
        conn.commit()

        # fin
        conn.close()
        GPIO.cleanup()
        sys.exit(0)

    # data commit
    conn.commit()

    # fin
    conn.close()
    GPIO.cleanup()

app.run("0.0.0.0", debug=True)

下記のエラーログが出力されます。
sqlite3.OperationalError: database is lockedが出力されると、
〇回目のカウントができなくなるようです。
同時に、5214: index(): count=2のカウントも進まなくなります。
sqlite3.OperationalError: database is lockedが出力される前は、
webブラウザ上にカウント回数を表示することもできております。

^C1回目
1回目
('pushed:', 1, 'time')
2回目
2回目
('pushed:', 2, 'time')
Traceback (most recent call last):
File "countupcustom.py", line 159, in <module>
table_wrt()
File "countupcustom.py", line 74, in table_wrt
c.execute(sql, params)
sqlite3.OperationalError: database is locked
pi@raspberrypi:~/dev/flask/countup5 $ 5214: index(): count=2
192.168.43.57 - - [15/Jun/2021 21:50:47] "GET / HTTP/1.1" 200 -
('pushed:', 3, 'time')
('pushed:', 4, 'time')
('pushed:', 5, 'time')
5214: index(): count=2
192.168.43.57 - - [15/Jun/2021 21:51:00] "GET / HTTP/1.1" 200 -
5214: index(): count=2

また、上記コードを実行してctl+Cで強制終了したあとは、
下記エラーが出力されるので、psとkillでプロセスを終了させなければなりません。
socket.error: [Errno 98] Address already in use

解決方法やご意見など、ご教示頂けないでしょうか。

Answer 1

このプログラムはどのように実行することを想定しているのでしょうか？
ラズパイのスイッチを押されたらカウントアップする処理と、Web処理が同じ関数に入っているのが理解できません。
WebはWeb、スイッチのカウントアップはカウントアップで別にし、dbで連携するように変えた方が良いと思います。

また、sqliteの処理ですが、sqliteは所詮ファイルなので適切に閉じてあげる必要があるはずです。

connectしたら必ずcloseする、書き込みのexecuteに対しては適切にcommitを入れるとした上で、エラー処理を正しく行った方が良いです。
(except にcommitが入っている理由がわかりません。エラーなのですから、rollbackするものでは？)
また、一番下にある以下ですが、これは実行されないのでは？

    # data commit
    conn.commit()

    # fin
    conn.close()
    GPIO.cleanup()

Comments

[dyrobin]

ご回答ありがとうございます。
スイッチをカウントアップしてDBに保存⇒ＤＢから取り出してwebに反映する
上記を違う関数で実装してみたいと思います。
sqliteの使い方につきましても、ありがとうございます。
勉強し直して、コードを考えてみます。