「Q4Mのテーブルが壊れたっぽいのだけども。。。」
との報告があり、状況を聞いてみた。
どうも、Queueに突っ込んだけども処理したくないデータがあったという理由で一部の行をDELETEしたとのこと。
で、早速DBを調べてみると、全部queue_waitで取り出したにも関わらず行数が0にならなかったり、
発行しているqueue_endが実行されずにずっとプロセスが残っていたりして大変カオスな状態になっていた。
(insertも止まっていた)
その場ではMySQLを強制的に再起動して、tableやschemaをdropして再作成してもらうことでことなきを得た。
が、今日帰ってきてQ4Mのページを見て謎が解決。
Q4Mの「Limitations and Known Issues」に
removal of multiple rows from a single DELETE statement is not atomic
(複数行に対する一つのDELETE文による削除はアトミックじゃありません)
と書いてあるじゃありませんか。
というわけで、これからQ4Mを使いたいという方でもし
「Queueに入れたけどやっぱり処理させたくないものは取りやめる」
というような要件がある場合
- 1行1DELETE文で削除する。
- もしくはignoreテーブルとかを作ってQueueを特定する情報を突っ込んでおいて、dequeueした時にignoreと照合する。
- QUEUEストレージエンジンを利用するschemaと、それ以外のschemaは分ける。
(あるいは別にMySQL5.0を用意してそっちに入れとく)
なので、Q4Mを使うときには
複数行に対して1つのDELETE文による削除はやってはいけない
です。
以上、ご参考まで〜
