<p>我不确定您对使用导入模块的承诺,您在您的问题,但我会通过使用熊猫和SQLalchemy来解决这个问题,因为这一切都很容易。你知道吗</p>
<p>以下是我如何处理您的问题:</p>
<pre><code>import os
import pandas as pd
from sqlalchemy import create_engine
localExtractFilePath="/Users/dalal"
config = {
'user':'root',
'password':'root',
'host':'127.0.0.1',
'database':'masterfiles'
}
def main():
engine = create_engine('mysql://{}:{}r@{}/{}'.format(config['user'],config['password'],config['host'],config['database']))
for file in os.listdir(localExtractFilePath):
if file.endswith("csv"):
print('{} file has been found. Loading to Pandas DF'.format(file))
#Load to a Pandas DataFrame Object (Documentation: https://pandas.pydata.org/pandas-docs/stable/generated/pandas.read_csv.html)
df = pd.read_csv(os.path.abspath(file))
df['symbol'] = os.path.splitext(file)[0][:-7]
print('Loading to DB....')
#Upload DF object to SQL (Documentation: https://pandas.pydata.org/pandas-docs/stable/generated/pandas.DataFrame.to_sql.html)
df.to_sql(con=engine, index=False, if_exists='append')
print('Done, on to the next file!')
if __name__ == '__main__':
main()
</code></pre>
<p>希望你觉得这有帮助!你知道吗</p>