Python：PIDベースのロックファイルを作成するためのモジュールですか？

Question

私はPythonスクリプトを書いていますが、これは長い間実行されるかもしれませんが、複数のインスタンス（cronを介して起動される）がそれぞれにステップしないようにしたいと思います他のつま先。これを行うための論理的な方法は、PIDベースのロックファイルであるようです...しかし、これを行うためのコードが既に存在する場合は、ホイールを再作成したくありません。

したがって、PIDベースのロックファイルの詳細を管理するPythonモジュールがありますか？

Answer 1

あなたはGPLv2のを使用することができる場合、Mercurialはそのためのモジュールがあります。

http://bitbucket.org/mirror/mercurial/src/tip/mercurial/lock.py

使用例：

from mercurial import error, lock 

try: 
    l = lock.lock("/path/to/lock", timeout=600) # wait at most 10 minutes 
    # do something 
except error.LockHeld: 
    # couldn't take the lock 
else: 
    l.release() 

Answer 2

これはあなたの助けになるかもしれません：lockfile

Answer 3

Iあなたが必要な情報を見つけると信じてhere。問題のページは、Pythonでデーモンを構築するためのパッケージを参照しています。このプロセスではPIDロックファイルを作成します。

Answer 4

recipe on ActiveState on creating lockfilesがあります。

ファイル名を生成するには、os.getpid()を使用してPIDを取得します。

Answer 5

私はそれらのすべてとかなり不満てきたので、私はこれを書いた：

class Pidfile(): 
    def __init__(self, path, log=sys.stdout.write, warn=sys.stderr.write): 
     self.pidfile = path 
     self.log = log 
     self.warn = warn 

    def __enter__(self): 
     try: 
      self.pidfd = os.open(self.pidfile, os.O_CREAT|os.O_WRONLY|os.O_EXCL) 
      self.log('locked pidfile %s' % self.pidfile) 
     except OSError as e: 
      if e.errno == errno.EEXIST: 
       pid = self._check() 
       if pid: 
        self.pidfd = None 
        raise ProcessRunningException('process already running in %s as pid %s' % (self.pidfile, pid)); 
       else: 
        os.remove(self.pidfile) 
        self.warn('removed staled lockfile %s' % (self.pidfile)) 
        self.pidfd = os.open(self.pidfile, os.O_CREAT|os.O_WRONLY|os.O_EXCL) 
      else: 
       raise 

     os.write(self.pidfd, str(os.getpid())) 
     os.close(self.pidfd) 
     return self 

    def __exit__(self, t, e, tb): 
     # return false to raise, true to pass 
     if t is None: 
      # normal condition, no exception 
      self._remove() 
      return True 
     elif t is PidfileProcessRunningException: 
      # do not remove the other process lockfile 
      return False 
     else: 
      # other exception 
      if self.pidfd: 
       # this was our lockfile, removing 
       self._remove() 
      return False 

    def _remove(self): 
     self.log('removed pidfile %s' % self.pidfile) 
     os.remove(self.pidfile) 

    def _check(self): 
     """check if a process is still running 

the process id is expected to be in pidfile, which should exist. 

if it is still running, returns the pid, if not, return False.""" 
     with open(self.pidfile, 'r') as f: 
      try: 
       pidstr = f.read() 
       pid = int(pidstr) 
      except ValueError: 
       # not an integer 
       self.log("not an integer: %s" % pidstr) 
       return False 
      try: 
       os.kill(pid, 0) 
      except OSError: 
       self.log("can't deliver signal to %s" % pid) 
       return False 
      else: 
       return pid 

class ProcessRunningException(BaseException): 
    pass 

はこのようなものを使用するために：

try: 
    with Pidfile(args.pidfile): 
     process(args) 
except ProcessRunningException: 
    print "the pid file is in use, oops." 

Answer 6

私は、これは古いスレッドです知っているが、私はまた、単にPythonのネイティブライブラリに依存する単純なロックを作成しました：

import fcntl 
import errno 


class FileLock: 
    def __init__(self, filename=None): 
     self.filename = os.path.expanduser('~') + '/LOCK_FILE' if filename is None else filename 
     self.lock_file = open(self.filename, 'w+') 

    def unlock(self): 
     fcntl.flock(self.lock_file, fcntl.LOCK_UN) 

    def lock(self, maximum_wait=300): 
     waited = 0 
     while True: 
      try: 
       fcntl.flock(self.lock_file, fcntl.LOCK_EX | fcntl.LOCK_NB) 
       return True 
      except IOError as e: 
       if e.errno != errno.EAGAIN: 
        raise e 
       else: 
        time.sleep(1) 
        waited += 1 
        if waited >= maximum_wait: 
         return False