Impedire l'esecuzione istanze simultanee di uno script python

Question

Eventuali duplicati:
Python: single instance of program

Ho bisogno di evitare un processo di cron esecuzione istanze simultanee quando un lavoro richiede più tempo per completare rispetto al programma di avvio intervallo. Sto cercando di usare il concetto di flock per raggiungere questo obiettivo, ma il modulo fcntl non si comporta come mi aspetto.

Qualcuno può dirmi perché questo funziona per evitare che due istanze simultanee:

import sys 
import time 
import fcntl 

file_path = '/var/lock/test.py' 
file_handle = open(file_path, 'w') 

try: 
    fcntl.lockf(file_handle, fcntl.LOCK_EX | fcntl.LOCK_NB) 
    print 'no other instance is running' 
    for i in range(5): 
     time.sleep(1) 
     print i + 1 

except IOError: 
    print 'another instance is running exiting now' 
    sys.exit(0) 

E perché questo non funziona:

import sys 
import time 
import fcntl 

def file_is_locked(file_path): 
    file_handle = open(file_path, 'w') 
    try: 
     fcntl.lockf(file_handle, fcntl.LOCK_EX | fcntl.LOCK_NB) 
     return False 
    except IOError: 
     return True 

file_path = '/var/lock/test.py' 

if file_is_locked(file_path): 
    print 'another instance is running exiting now' 
    sys.exit(0) 
else: 
    print 'no other instance is running' 
    for i in range(5): 
     time.sleep(1) 
     print i + 1 

Answer 1

Il mio modesto parere (sebbene possa essere completamente sbagliato) è che file_handle è locale alla funzione (nel secondo caso) e quindi viene distrutto una volta che la funzione è stata completata.

Il seguente codice sembra funzionare come previsto:

#!/usr/bin/env python 
#http://stackoverflow.com/questions/14406562/prevent-running-concurrent-instances-of-a-python-script 

import sys 
import time 
import fcntl 

file_handle = None 

def file_is_locked(file_path): 
    global file_handle 
    file_handle= open(file_path, 'w') 
    try: 
     fcntl.lockf(file_handle, fcntl.LOCK_EX | fcntl.LOCK_NB) 
     return False 
    except IOError: 
     return True 

file_path = '/var/lock/test.py' 

if file_is_locked(file_path): 
    print 'another instance is running exiting now' 
    sys.exit(0) 
else: 
    print 'no other instance is running' 
    for i in range(5): 
     time.sleep(1) 
     print i + 1 

Si noti che l'unica cosa che ho fatto è la creazione file_handle come variabile globale (anche se ho copiato l'intero codice per avere un esempio di lavoro)

Answer 2

modo più semplice sarebbe quella di creare un file/tmp/scriptlock all'inizio dello script e controlla se quel file esiste prima di lavorare. Assicurati che il file di blocco venga rimosso anche alla fine dell'elaborazione.

Answer 3

Come ho accennato nella mia risposta alla risposta di @ BorrajaX, dato che sembra che tu sia legato a POSIX in ogni caso, puoi provare a usare uno native named semaphore.

Answer 4

è possibile utilizzare il programma di setlock da daemontools di D. J. Bernstein, invece:

http://cr.yp.to/daemontools/setlock.html