Como usar python para consultar banco de dados em paralelo
Eu tenho duas funções que eu uso para consultar o banco de dados. Supondo duas consultas separadas, como executá-las em paralelo para consultar o mesmo banco de dados e também aguardar o retorno de ambos os resultados antes de continuar a execução do restante do código?
def query1(param1, param2):
result = None
logging.info("Connecting to database...")
try:
conn = connect(host=host, port=port, database=db)
curs = conn.cursor()
curs.execute(query)
result = curs
curs.close()
conn.close()
except Exception as e:
logging.error("Unable to access database %s" % str(e))
return result
def query2(param1, param2):
result = None
logging.info("Connecting to database...")
try:
conn = connect(host=host, port=port, database=db)
curs = conn.cursor()
curs.execute(query)
result = curs
curs.close()
conn.close()
except Exception as e:
logging.error("Unable to access database %s" % str(e))
return result