def __init__(self, file, fresh=False):
self.file = file
info = os.stat(self.file)
self.hash = str(hash(info.st_size + round(info.st_mtime))) # Why round: during file copying we may cut mikrosecond part behind mantisa.
#MailDraft.setHash(self.hash)
#MailDraft.setDir(os.path.dirname(file) + "/")
# cache-file s metadaty zdrojoveho souboru
Config.setCacheDir(os.path.dirname(file) + "/" + ntpath.basename(self.file) + "_convey" + self.hash + "/")
self.cacheFile = Config.getCacheDir() + ntpath.basename(self.file) + ".cache" #"cache/" +
if os.path.isfile(self.cacheFile) and not fresh:
print("File {} has already been processed.".format(self.file))
#import pdb;pdb.set_trace()
try: # try to depickle
self.csv = jsonpickle.decode(open(self.cacheFile, "r").read(), keys = True)
except:
print("Cache file loading failed, let's process it all again. If you continue, cache gets deleted.")
input()
if Config.isDebug():
ipdb.set_trace()
self._treat()
if self.csv:
try:
if self.csv.isAnalyzed:
self.csv.informer.soutInfo()
elif self.csv.isFormatted:
self.csv.informer.soutInfo()
s = "It seems the file has already been formatted." # X Continue to analysis (or you'll be asked to do format again)?"
print(s)
#if Dialogue.isYes(s):
# self.csv.runAnalysis()
#else:
# self._treat()
except BdbQuit: # we do not want to catch quit() signal from ipdb
print("Stopping.")
quit()
except Exception as e:
#ipdb.set_trace()
print(e)
print("Format of the file may have changed since last time. Let's process it all again. If you continue, cache gets deleted.")
self._treat()
else:
self._treat() # process file
else:
if not os.path.exists(Config.getCacheDir()):
os.makedirs(Config.getCacheDir())
self._treat() # process file
##
# Store
评论列表
文章目录
