<bdo id='ZLDte'></bdo><ul id='ZLDte'></ul>
  • <i id='ZLDte'><tr id='ZLDte'><dt id='ZLDte'><q id='ZLDte'><span id='ZLDte'><b id='ZLDte'><form id='ZLDte'><ins id='ZLDte'></ins><ul id='ZLDte'></ul><sub id='ZLDte'></sub></form><legend id='ZLDte'></legend><bdo id='ZLDte'><pre id='ZLDte'><center id='ZLDte'></center></pre></bdo></b><th id='ZLDte'></th></span></q></dt></tr></i><div id='ZLDte'><tfoot id='ZLDte'></tfoot><dl id='ZLDte'><fieldset id='ZLDte'></fieldset></dl></div>
    1. <small id='ZLDte'></small><noframes id='ZLDte'>

      <legend id='ZLDte'><style id='ZLDte'><dir id='ZLDte'><q id='ZLDte'></q></dir></style></legend>

      1. <tfoot id='ZLDte'></tfoot>

      2. 使用 pySpark 将 DataFrame 写入 mysql 表

        时间:2023-08-22

      3. <i id='y5R2n'><tr id='y5R2n'><dt id='y5R2n'><q id='y5R2n'><span id='y5R2n'><b id='y5R2n'><form id='y5R2n'><ins id='y5R2n'></ins><ul id='y5R2n'></ul><sub id='y5R2n'></sub></form><legend id='y5R2n'></legend><bdo id='y5R2n'><pre id='y5R2n'><center id='y5R2n'></center></pre></bdo></b><th id='y5R2n'></th></span></q></dt></tr></i><div id='y5R2n'><tfoot id='y5R2n'></tfoot><dl id='y5R2n'><fieldset id='y5R2n'></fieldset></dl></div>

            <tbody id='y5R2n'></tbody>

            <tfoot id='y5R2n'></tfoot>
              <bdo id='y5R2n'></bdo><ul id='y5R2n'></ul>
              <legend id='y5R2n'><style id='y5R2n'><dir id='y5R2n'><q id='y5R2n'></q></dir></style></legend>

                <small id='y5R2n'></small><noframes id='y5R2n'>

                  本文介绍了使用 pySpark 将 DataFrame 写入 mysql 表的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

                  问题描述

                  我正在尝试将记录插入到 MySql 表中.该表包含 idname 作为列.

                  I am attempting to insert records into a MySql table. The table contains id and name as columns.

                  我在 pyspark shell 中执行如下操作.

                  I am doing like below in a pyspark shell.

                  name = 'tester_1'
                  id = '103'  
                  import pandas as pd
                  l = [id,name]
                  
                  df = pd.DataFrame([l])
                  
                  df.write.format('jdbc').options(
                        url='jdbc:mysql://localhost/database_name',
                        driver='com.mysql.jdbc.Driver',
                        dbtable='DestinationTableName',
                        user='your_user_name',
                        password='your_password').mode('append').save()
                  

                  我收到以下属性错误

                  AttributeError: 'DataFrame' 对象没有属性 'write'

                  我做错了什么?从 pySpark

                  推荐答案

                  使用 Spark DataFrame 而不是 pandas',因为 .write 仅适用于 Spark Dataframe

                  Use Spark DataFrame instead of pandas', as .write is available on Spark Dataframe only

                  所以最终的代码可能是

                  data =['103', 'tester_1']
                  
                  df = sc.parallelize(data).toDF(['id', 'name'])
                  
                  df.write.format('jdbc').options(
                        url='jdbc:mysql://localhost/database_name',
                        driver='com.mysql.jdbc.Driver',
                        dbtable='DestinationTableName',
                        user='your_user_name',
                        password='your_password').mode('append').save()
                  

                  这篇关于使用 pySpark 将 DataFrame 写入 mysql 表的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持html5模板网!

                  上一篇:pyspark mysql jdbc load 调用 o23.load 时发生错误 没有合 下一篇:Spark SQL 和 MySQL- SaveMode.Overwrite 不插入修改的数据

                  相关文章

                  最新文章

                1. <legend id='34Dzw'><style id='34Dzw'><dir id='34Dzw'><q id='34Dzw'></q></dir></style></legend>

                      <tfoot id='34Dzw'></tfoot>
                      <i id='34Dzw'><tr id='34Dzw'><dt id='34Dzw'><q id='34Dzw'><span id='34Dzw'><b id='34Dzw'><form id='34Dzw'><ins id='34Dzw'></ins><ul id='34Dzw'></ul><sub id='34Dzw'></sub></form><legend id='34Dzw'></legend><bdo id='34Dzw'><pre id='34Dzw'><center id='34Dzw'></center></pre></bdo></b><th id='34Dzw'></th></span></q></dt></tr></i><div id='34Dzw'><tfoot id='34Dzw'></tfoot><dl id='34Dzw'><fieldset id='34Dzw'></fieldset></dl></div>

                        <bdo id='34Dzw'></bdo><ul id='34Dzw'></ul>

                      <small id='34Dzw'></small><noframes id='34Dzw'>