Preciso fazer uma série de operações envolvendo arquivos binários (não dá pra usar BD), e preciso garantir que elas terminem com sucesso mesmo em caso de falha no meio da operação. Para isso, não vejo saída a não ser implementar um sistema de journaling manualmente. Comecei a escrever um código, mas não estou seguro se está correto (i.e. se não existem casos em que uma falha no meio da tarefa pode colocá-lo em um estado inconsistente - inclusive falha na própria escrita do journal).
Existe algo pronto nesse sentido? E se não existe, há algum problema na minha tentativa de solução abaixo?
def nova_tarefa(args):
refazer_journal() # Refaz o que ficou inacabado da última vez (se houver)
with open('args.json', 'w') as f:
json.dump(args, f) # Prepara as novas tarefas
with open('journal.txt', 'w') as f:
f.write('comecar\n') # Coloca as novas tarefas no journal
refazer_journal() # Faz as novas tarefas
def refazer_journal():
try:
with open('journal.txt', 'r') as f:
passos = [x.strip() for x in f.readlines() if x.strip()]
except:
if not os.path.exists('journal.txt'):
passos = []
else:
raise
if not passos: # Se não há nada inacabado, termina
return
with open('args.json', 'r') as f:
args = json.load(f)
# Realiza as tarefas que ainda não foram marcadas como concluídas
for indice,tarefa in enumerate(args['tarefas']):
if len(passos) <= indice+1:
realizar_tarefa_indepotente(tarefa)
with open('journal.txt', 'a') as f:
f.write('\ntarefa concluida\n')
with open('journal.txt', 'w') as f:
pass # Tudo foi feito com sucesso: esvazia o journal
(Nota: o que está escrito no journal - comecar
, tarefa concluida
- não é importante, se apenas uma letra que seja for escrita na linha já se considera que o passo foi bem-sucedido)
Código para teste (comigo funcionou sempre - inclusive editando o journal.txt
para introduzir uma série de erros):
def realizar_tarefa_indepotente(tarefa):
if 'falhar' in tarefa:
raise Exception('Tarefa falhou!')
print 'Realizando tarefa: ' + tarefa['nome']
tarefa_ok = {'tarefas':[{'nome':'foo'}, {'nome':'bar'}, {'nome':'baz'}]}
falha_3 = {'tarefas':[{'nome':'foo'}, {'nome':'bar'}, {'nome':'baz','falhar':True}]}
falha_2 = {'tarefas':[{'nome':'foo'}, {'nome':'bar','falhar':True}, {'nome':'baz'}]}
falha_1 = {'tarefas':[{'nome':'foo','falhar':True}, {'nome':'bar'}, {'nome':'baz'}]}
falha_1_3 = {'tarefas':[{'nome':'foo','falhar':True}, {'nome':'bar'}, {'nome':'baz','falhar':True}]}