我正试图利用MySQL将数据从一个数据库迁移到HANA。我们目前在工作中实现这种迁移的方式是手动的,但是计划是每天运行一个脚本来收集前一天的数据(存储在MySQL中),并将其转移到HANA使用他们的分析工具。我编写了一个带有两个函数的脚本,一个连接到MySQL,并将查询中的数据临时存储在Pandas中。第二个函数使用sqlalchemy连接器创建一个引擎,我将其输入到Pandas的to_sql函数中,以便将数据存储到HANA中。
下面是对MySQL的第一个函数调用
def connect_to_mysql(query):
try:
#connect to the db