Skip to content
Snippets Groups Projects
Commit 7c48a37f authored by thomaswoehlke's avatar thomaswoehlke
Browse files

Merge remote-tracking branch 'origin/main' into main

# Conflicts:
#	data
parents 4e14b9e9 7d54802f
No related branches found
No related tags found
No related merge requests found
Subproject commit 317532010c74366f89fa95c068d3f97af39f8550 Subproject commit 4607a0547d5be61e8e7b955e570d429af054b93b
...@@ -11,7 +11,7 @@ class AdminService: ...@@ -11,7 +11,7 @@ class AdminService:
app.logger.debug("------------------------------------------------------------") app.logger.debug("------------------------------------------------------------")
self.__database = database self.__database = database
self.limit_nr = 20 self.limit_nr = 20
self.file_path = '..'+os.sep+'data'+os.sep+'db'+os.sep+'covid19data.sql' self.file_path = '..'+os.sep+'..'+os.sep+'data'+os.sep+'db'+os.sep+'covid19data.sql'
app.logger.debug("------------------------------------------------------------") app.logger.debug("------------------------------------------------------------")
app.logger.info(" Admin Service [ready]") app.logger.info(" Admin Service [ready]")
...@@ -24,13 +24,13 @@ class AdminService: ...@@ -24,13 +24,13 @@ class AdminService:
def run_admin_database_dump(self): def run_admin_database_dump(self):
app.logger.info(" run database dump [begin]") app.logger.info(" run database dump [begin]")
app.logger.info("------------------------------------------------------------") app.logger.info("------------------------------------------------------------")
app.logger.info(os.getcwd())
user = app.config['SQLALCHEMY_DATABASE_USER'] user = app.config['SQLALCHEMY_DATABASE_USER']
url = app.config['SQLALCHEMY_DATABASE_HOST'] url = app.config['SQLALCHEMY_DATABASE_HOST']
db = app.config['SQLALCHEMY_DATABASE_DB'] db = app.config['SQLALCHEMY_DATABASE_DB']
cmd = 'pg_dump -U '+user+' -h '+url+' '+db\ cmd = 'pg_dump --if-exists --clean --no-tablespaces '\
+' --clean --if-exists --no-tablespaces '\
+' --on-conflict-do-nothing --rows-per-insert=1000 --column-inserts '\ +' --on-conflict-do-nothing --rows-per-insert=1000 --column-inserts '\
+' --quote-all-identifiers --no-privileges > '\ +' --quote-all-identifiers --no-privileges -U '+user+' -h '+url+' '+db+' > '\
+ self.file_path + self.file_path
app.logger.info(" start: "+str(cmd)) app.logger.info(" start: "+str(cmd))
returncode = self.__run_ome_shell_command(cmd) returncode = self.__run_ome_shell_command(cmd)
...@@ -48,21 +48,24 @@ class AdminService: ...@@ -48,21 +48,24 @@ class AdminService:
result = subprocess.run(args, shell=True, check=True, capture_output=True, encoding='UTF-8') result = subprocess.run(args, shell=True, check=True, capture_output=True, encoding='UTF-8')
returncode = result.returncode returncode = result.returncode
except subprocess.CalledProcessError as error: except subprocess.CalledProcessError as error:
app.logger.warning("WARN: AdminService.__run_ome_shell_command") app.logger.warning("---------------------------------------------------------")
app.logger.warning("cmd :::" + cmd + ":::") app.logger.warning(" WARN: AdminService.__run_ome_shell_command")
app.logger.warning("error :::" + str(error) + ":::") app.logger.warning("---------------------------------------------------------")
app.logger.warning("WARN: AdminService.__run_ome_shell_command") app.logger.warning(" cmd: :::" + cmd + ":::")
app.logger.warning(" erro: :::" + str(error) + ":::")
app.logger.warning("---------------------------------------------------------")
return returncode return returncode
def run_admin_database_dump_reimport(self): def run_admin_database_dump_reimport(self):
flash(" run database dump reimport [begin]") # flash(" run database dump reimport [begin]")
app.logger.info(" run database dump reimport [begin]") app.logger.info(" run database dump reimport [begin]")
app.logger.info("------------------------------------------------------------") app.logger.info("------------------------------------------------------------")
user = app.config['SQLALCHEMY_DATABASE_USER'] user = app.config['SQLALCHEMY_DATABASE_USER']
url = app.config['SQLALCHEMY_DATABASE_HOST'] url = app.config['SQLALCHEMY_DATABASE_HOST']
db = app.config['SQLALCHEMY_DATABASE_DB'] db = app.config['SQLALCHEMY_DATABASE_DB']
one_cmd = 'psql -U ' + user + ' -h ' + url + ' ' + db + ' < ' + self.file_path
cmd_list = [ cmd_list = [
'psql -U ' + user + ' -h ' + url + ' ' + db + ' < ' + self.file_path one_cmd
] ]
for cmd in cmd_list: for cmd in cmd_list:
returncode = self.__run_ome_shell_command(cmd) returncode = self.__run_ome_shell_command(cmd)
...@@ -70,7 +73,7 @@ class AdminService: ...@@ -70,7 +73,7 @@ class AdminService:
app.logger.info(msg) app.logger.info(msg)
app.logger.info(" run database dump reimport [done]") app.logger.info(" run database dump reimport [done]")
app.logger.info("------------------------------------------------------------") app.logger.info("------------------------------------------------------------")
flash(" run database dump reimport [done]") # flash(" run database dump reimport [done]")
return self return self
def run_admin_database_drop_and_create(self): def run_admin_database_drop_and_create(self):
......
...@@ -26,7 +26,7 @@ class ApplicationServiceConfig: ...@@ -26,7 +26,7 @@ class ApplicationServiceConfig:
self.cvsfile_name = cvsfile_name self.cvsfile_name = cvsfile_name
self.url_src = url_src self.url_src = url_src
self.download_path = self.data_path + os.sep + self.cvsfile_name self.download_path = self.data_path + os.sep + self.cvsfile_name
self.cvsfile_path = ".." + os.sep + self.data_path + os.sep + self.cvsfile_subpath + os.sep + self.cvsfile_name self.cvsfile_path = self.data_path + os.sep + self.cvsfile_subpath + os.sep + self.cvsfile_name
self.msg_job = "download FILE: "+self.cvsfile_name+" from "+self.url_src self.msg_job = "download FILE: "+self.cvsfile_name+" from "+self.url_src
self.msg_ok = "downloaded FILE: " + self.cvsfile_path + " from " + self.url_src self.msg_ok = "downloaded FILE: " + self.cvsfile_path + " from " + self.url_src
self.msg_error = "Error while downloading: " + self.cvsfile_path + " from " + self.url_src self.msg_error = "Error while downloading: " + self.cvsfile_path + " from " + self.url_src
......
File moved
File moved
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment