【问题标题】:moving a dataframe to redshift using pyspark使用 pyspark 将数据框移动到红移
【发布时间】:2018-06-18 04:17:43
【问题描述】:

我有一张红移表格

id, name, address
1, 'aaa', 'xxx'
2, 'bbb', 'yyy'

我在 pyspark 中有一个数据框

id, name, address
1, 'ccc', 'zzz'
5, 'ddd', 'xyx'

现在我需要使用 upsert 模式将 pyspark 中的数据帧上传到 redshift 表。

任何人都可以帮助我如何做到这一点

【问题讨论】:

    标签: pyspark amazon-redshift


    【解决方案1】:

    为此使用Redshift Data Source for Apache Spark。请记住,在加载此数据之前,这些表应该已经存在于 Redshift 中。

    【讨论】:

      【解决方案2】:

      首先,您需要在 redshift 中检查您的预期表是否存在。然后你可以从下面的代码中获得帮助。

      # Write back to a table
      df.write \
        .format("com.databricks.spark.redshift") \
        .option("url", "jdbc:redshift://redshifthost:5439/database?user=username&password=pass") \
        .option("dbtable", "my_table_copy") \
        .option("tempdir", "s3n://path/for/temp/data") \
        .mode("error") \
        .save()
      

      【讨论】:

      • 追加数据框行时这不起作用
      猜你喜欢
      • 2021-07-28
      • 2021-10-06
      • 2020-10-28
      • 2021-01-05
      • 1970-01-01
      • 2019-09-22
      • 1970-01-01
      • 1970-01-01
      • 2018-11-25
      相关资源
      最近更新 更多