Duda con respecto a pyinotify - Monitoreando sistemas de archivos

[Montes28]

Hola amigos espero me puedan ayudar,

Me encuentro monitoreando un sistema de archivos y necesito el evento en el que termina de grabarse el archivo en disco

hasta el momento este es mi codigo, este funciona para cuando se crea el archivo

Código Python:

import pyinotify
 
class EventHandler(pyinotify.ProcessEvent):
 
    def process_IN_CREATE(self, event):
        print "Creacion del archivo :", event.pathname
    archivo = event.name
    ruta = event.pathname
    archi=open('datos.txt','a')
    archi.write('archivo:'+ ' '+ event.name + ' ' + 'ruta:'+ ' '+ event.pathname)
    archi.write('\n')
        archi.close()
 
wm = pyinotify.WatchManager()
mask = pyinotify.IN_CREATE
 
handler = EventHandler()
notifier = pyinotify.Notifier(wm, handler)
wdd = wm.add_watch('/resources', mask, rec=True)
notifier.loop()
 

[Carlangueitor]

Ese código no funciona no está correctamente identado.

Saludos

[Montes28]

Carlangueitor gracias por responder, tienes razon queda mal identado al copiarlo

tienes algun aporte acerca del evento en el que termina de grabarse el archivo en disco ?

Código Python:

import pyinotify
 
class EventHandler(pyinotify.ProcessEvent):
 
    def process_IN_CLOSE_WRITE(self, event):
        print "Creacion del archivo :", event.pathname
        archivo = event.name
        ruta = event.pathname
        archi=open('datos.txt','a')
        archi.write('archivo:'+ ' '+ event.name + ' ' + 'ruta:'+ ' '+ event.pathname)
        archi.write('\n')
        archi.close()
 
wm = pyinotify.WatchManager()
mask = pyinotify.IN_CLOSE_WRITE
 
handler = EventHandler()
notifier = pyinotify.Notifier(wm, handler)
wdd = wm.add_watch('/resources', mask, rec=True)
notifier.loop()
 

[Carlangueitor]

Sí, yo usaría otro evento ¿ya revisaste la documentación para ver si hay algún otro evento que te funcione?

[Montes28]

estoy utilizando el evento IN_CLOSE_WRITE pero obtengo el siguiente error

psycopg2.connect(database="python", user="postgres", password="hoe798css", host="192.168.102.6", port="5432")
^
IndentationError: unexpected indent

este es mi codigo

Código Python:

import pyinotify
import psycopg2
 
class MyEventHandler(pyinotify.ProcessEvent):
 
    def process_IN_CLOSE_WRITE(self, event):
        print "CLOSE_WRITE event:", event.pathname
        print "Nombre :", event.name
        print "Ruta", event.pathname
        archivo = event.name
        ruta = event.pathname
        url = "http://192.168.102.8/repo_webcam/balcones-ruiz/"+archivo
        tamano = len(archivo)
        if tamano == 25:
            anno=archivo[5:9]
            mes=archivo[9:11]
            dia=archivo[11:13]
            hora=archivo[14:16]
            minuto=archivo[16:18]
            segundo=archivo[18:20]
            archi=open('balcones-ruiz.txt','a')
            archi.write('archivo:'+ ' '+ event.name + ' ' + 'ruta:'+ ' '+ event.pathname)
            archi.write('\n')
            archi.close()
            conn = psycopg2.connect(database="python", user="postgres", password="hoe798css", host="192.168.102.6", port="5432")
            print "Opened database successfully"
            cur = conn.cursor()
            cur.execute("INSERT INTO prueba VALUES(nextval('prueba_id_seq'), %s, %s, %s)", (anno+"-"+ mes +"-" + dia +" " + hora +":"+ minuto +":"  +segundo,url,ruta))
            conn.commit()
            print "Records created successfully";
            conn.close()
            
def main():
    # watch manager
    wm = pyinotify.WatchManager()
    wm.add_watch('/monitoreo/camip/balcones-ruiz', pyinotify.ALL_EVENTS, rec=True)
 
    # event handler
    eh = MyEventHandler()
 
    # notifier
    notifier = pyinotify.Notifier(wm, eh)
    notifier.loop()
 
if __name__ == '__main__':
    main()
 

[alzacon]

IndentationError: unexpected indent

No será que estás mezclando tabuladores y espacios en esa línea. Porqúe aunque parezca que está bien identado en realidad no es así.