【问题标题】:Inserting large number of data rows into cloudsql table via PyMySql from .csv通过 .csv 中的 MySql 将大量数据行插入云 sql 表
【发布时间】:2019-09-03 23:06:31
【问题描述】:

我是 CloudSQL 新手,我正在尝试插入 40 多个不同列和超过 150 万行的记录。但是我无法在 Google CloudSQL 中执行此操作。我已经采取了下面列出的许多措施来解决这个问题,但我得到的主要错误是:

ERROR:
textPayload:  "2019-04-12T06:10:47.348295Z 8554 [Note] Aborted connection 8554 to db: 'xxxxx_xxx' user: 'root' host: 'x.x.x.x' (Got an error reading communication packets)"  

总结:

  1. 我正在使用 Python,PyMySql 将 150 万行数据插入到一个 35 列的表中
  2. 实例、数据库、表已在 CloudSQL 中创建。
  3. 系统配置:vCPU - 4,内存 - 15 GB,SSD 存储 - 10 GB
  4. 我可以在本地系统中完全加载这些数据。
  5. 在 Google CloudSQl 中,部署时间极长,部署成功。
  6. 但是当我检查我的桌子时,它是空的。
  7. 实例中的MySql 错误日志显示如上。

我已经尝试了以下操作:

  • 现在使用 API URL/ .txt / .json 文件进行上传,而不是使用 .csv

  • 认为是系统问题,我将系统从 8GB 内存升级到 15GB 内存。

  • 考虑到 SQL 默认配置会造成限制,我添加了以下内容:

    • sql_mode : MAXDB,NO_AUTO_CREATE_USER

    • max_allowed_pa​​cket:1073741824

    • net_read_timeout:4294967295

    • wait_timeout:31536000

  • 插入的行数较少,能够插入的最大行数 = 100

def adddata():
    try:
        conn = pymysql.connect(unix_socket='/cloudsql/' + 'karto-235001:asia-east1:karto', user='xxx', password='xxx', db='xxx')
        cur = conn.cursor()
        insert_ = "INSERT INTO data_table(a, b, c) VALUES (%s, %s, %s)"
        with open('info.csv', newline='') as myFile:
            reader = csv.reader(myFile)
            for item in reader:
                cur.execute(insert_, (item[3], item[4], item[5]))
            conn.commit()
            cur.close()
    finally:
        conn.close()

我在网上查了一下,已经实现了 CloudSQL 和其他 stack-overflow 用户推荐的解决方案。如果有人能识别出我做错了什么,或者我的代码或配置是否存在问题?非常感谢。

【问题讨论】:

    标签: mysql python-3.x google-cloud-sql pymysql


    【解决方案1】:

    我了解到您想使用 Python 上传包含在 CSV 文件中的信息。您是否尝试过直接导入数据库?您可以按照链接[1]中的步骤进行操作。

    与此同时,我将尝试复制您的案例。您可能还想检查您的安装和配置是否正确。

    验证您的 Cloud SQL 实例和连接 [2] 以及您的 Python 安装[3]。

    [1]https://cloud.google.com/sql/docs/mysql/import-export/importing#csv
    [2]https://cloud.google.com/sql/docs/mysql/connect-compute-engine
    [3]https://cloud.google.com/python/setup
    

    【讨论】:

    • 对迟到的回复表示歉意。您直接导入数据库的建议对我有用!谢谢!
    猜你喜欢
    • 1970-01-01
    • 2020-02-06
    • 1970-01-01
    • 2020-08-28
    • 1970-01-01
    • 1970-01-01
    • 2016-11-25
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多