MySQLの永続的接続が切れる

Question

前提・実現したいこと

python3とMySQLモジュールmysql-connectorを使ってイベント発生によるMySQLデータベースにログを出力するデーモンスクリプトを作成しました。

イベントによるMySQLの接続/切断はコストが掛かるので、デーモン起動時に一度だけ接続し、イベントが発生したときにその接続ハンドルを使ってINSERT処理を行うようにしています。

ちなみにイベントとはMQTTによるデータの受信をおこなっています。

発生している問題・エラーメッセージ

通常イベント発生と同時にSQLにてINSERTを実行し、所定のテーブルに書込まれていますが、突然書き込まれなくなってしまいます。
デーモンを再起動すれば、また書込まれるようになります。

書込まれなくなったときのエラーメッセージ以下のものが返されますので、おそらくデーモン起動時の接続が切断されたのだと思います。

"MySQL Connection not available."

実際に接続が切れるケースとして一晩とか長時間イベントが発生せず接続したままアイドル状態が続いているときに起こるようなのです。

実装

接続を永続するためにmysql-connectorにはpingメソッドがあるので、それに依存して再接続の実装はしていないのですが、pingメソッドが機能していないように思うので、なにか使い方の問題や注意点などがあればご指摘賜りたいと思います。

要約したソースコード

import paho.mqtt.client as mqtt
import mysql.connector

def on_message(client, userdata, msg): # イベントドリブン
    sql = "INSERT INTO event (topic) value ('{0}')".format(msg.topic)
    cur = conn.cursor() 
    cur.execute(sql)
    cur.close()

# MySQLコネクションの作成
conparm = {'host':'localhost','port':'3306', 'user': 'hoge', 'password':'hoge','database':'hoge'}
conn = mysql.connector.connect(**conparm)
conn.autocommit = True
conn.ping(reconnect=True) # 接続が切れた時に再接続してくれるよう設定

client = mqtt.Client(protocol=mqtt.MQTTv311) # MQTTブローカーに接続
client.on_message = on_message  # 受信データのイベントドリブンの指定
client.loop_forever() # 受信データのイベントを永続的に待ち受ける

補足情報（FW/ツールのバージョンなど）

OS: CentOS7
DBMS: MySQL 5.7.29
言語: Python 3.6.8
MySQLモジュール: mysql-connector-python 8.0.19

Comments

[hoshi-takanori]

conn.ping は定期的に ping してくれる設定ではなく、その時に ping するだけ (なので、DB アクセスのたびに呼ぶ必要がある) ように見えますけど。
https://bitworks.software/en/2019-03-12-tornado-persistent-mysql-connection-strategy.html

[XCUBE]

おっしゃるとおりping を定期的にしてくれるのではないようですね。誤認していました。ありがとうございました。
ベストアンサーです。

今回の場合、DBのアクセスのタイミングはイベントに依存するのでスレッドの中で定期的にpingメソッドを呼び出すようにします。

ありがとうございました。

Answer 1

hoshi-takanoriさんよりご指摘いただいたことで、別スレッドから定期的にpingを行うよう実装し、今のころ問題なくコネクションが保たれています。

スレッド間で同じコネクションを参照するところに一抹の不安がありますが、ping程度なら特に問題ないと思ってこのまま様子を見ておきます。