Beanstalkd Buriedになったジョブを削除する
Beanstalkdにうっかり不正なデータのジョブを投入。プログラムで処理できずに「Buried」になったまま残ることがあります。
放置しておいても良いのですが、気になるので削除する方法をメモ。
beanstalkc
Pythonで簡単なプログラムを作成し削除します。
使用する接続ライブラリはこちら。
https://github.com/earl/beanstalkc
beanstalkc.pyをダウンロードしてこれから作成するプログラムと
同じ階層に置いておくだけで動いてくれます。
tube_nameに残っているBuriedなジョブを削除するサンプルは
こんな感じになりました。
- # -*- coding:utf-8 -*-
- import beanstalkc
- beanstalk = beanstalkc.Connection(host='192.168.1.101', port=11300)
- beanstalk.use('tube_name')
- while True:
- job = beanstalk.peek_buried()
- if not job:
- break
- job.delete()
コメント