Faciliter la surcharge des DeleteFileOp.postcommit_event et AddFileOp.postcommit_event
Sur FranceArchives nous avons besoin de surcharger les DeleteFileOp.postcommit_event et AddFileOp.postcommit_event pour chaque fichier traité. Serait-il possible d'avoir la possibilité d'appeler du code sur chaque donnée :
class S3DeleteFileOp(DataOperationMixIn, LateOperation):
containercls = list
def new_func_process_data(self, storage, key, eid, attr):
pass
def postcommit_event(self):
for storage, key, eid, attr in self.get_data():
self.info('Deleting object %s.%s (%s/%s) from S3',
eid, attr, storage.bucket, key)
resp = storage.s3cnx.delete_object(Bucket=storage.bucket, Key=key)
if resp.get('ResponseMetadata', {}).get('HTTPStatusCode') >= 300:
self.error('S3 object deletion FAILED: %s', resp)
else:
self.debug('S3 object deletion OK: %s', resp)
self.new_func_process_data(storage, key, eid, attr)