Glue AWS：调用 o60.getDynamicFrame 时发生错误答案

【问题标题】：Glue AWS: error occurred while calling o60.getDynamicFrameGlue AWS：调用 o60.getDynamicFrame 时发生错误
【发布时间】：2018-10-18 19:57:41
【问题描述】：

我已经定义了一个基本脚本来创建一个 DF，其中的数据来自我的一个 redshift 表。我运行了这个过程，但我一直在为一个我无法解释的消息而苦苦挣扎。

日志中的错误输出为：

"/mnt/yarn/usercache/root/appcache/application_1525803778049_0004/container_1525803778049_0004_01_000001/py4j-0.10.4-src.zip/py4j/protocol.py", line 319, in get_return_value py4j.protocol.Py4JJavaError: An error occurred while calling o60.getDynamicFrame. : java.lang.UnsupportedOperationException: empty.reduceLeft at scala.collection.

import sys
from awsglue.transforms import *
from awsglue.utils import getResolvedOptions
from pyspark.context import SparkContext
from awsglue.context import GlueContext
from awsglue.dynamicframe import DynamicFrame, DynamicFrameReader, DynamicFrameWriter, DynamicFrameCollection
from pyspark.sql.functions import lit
from awsglue.job import Job

sc = SparkContext()
glueContext = GlueContext(sc)
spark = glueContext.spark_session
job = Job(glueContext)

table = glueContext.create_dynamic_frame.from_options(connection_type="redshift", connection_options = 
    {"url": "jdbc:redshift://xxxxx.yyyyy.us-east-1.redshift.amazonaws.com:5439/db",
    "user": "yyyy",
    "password": "yyyyy",
    "dbtable": "schema.table_name",
    "redshiftTmpDir": "s3://aws-glue-temporary-accountnumber-us-east-1/"},
    format="orc", 
    transformation_ctx="table" )

table.show()

dfred = table.toDF().createOrReplaceTempView("table_df")

job.commit()

感谢您为我提供的任何帮助。非常感谢

【问题讨论】：

标签： pyspark spark-dataframe amazon-redshift etl aws-glue

【解决方案1】：

好吧，在继续努力解决这个问题之后，我通过了DynamicFrame 的官方代码类所以，我在我的代码中添加了一个应用格式转换，以映射来自 redshift 中读取表的结果以及拉出的方法我跳过了参数transformation_ctx 的表，该参数在错误 o60

中失败

我的最终版本代码是：

import sys
from awsglue.transforms import *
from awsglue.utils import getResolvedOptions
from pyspark.context import SparkContext
from awsglue.context import GlueContext
from awsglue.dynamicframe import DynamicFrame, DynamicFrameReader, DynamicFrameWriter, DynamicFrameCollection
from pyspark.sql.functions import lit
from awsglue.job import Job

sc = SparkContext()
glueContext = GlueContext(sc)
spark = glueContext.spark_session
job = Job(glueContext)

table = glueContext.create_dynamic_frame.from_options(connection_type="redshift", connection_options = 
    {"url": "jdbc:redshift://xxxxx.yyyyy.us-east-1.redshift.amazonaws.com:5439/db",
    "user": "yyyy",
    "password": "yyyyy",
    "dbtable": "schema.table_name",
    "redshiftTmpDir": "s3://aws-glue-temporary-accountnumber-us-east-1/"}
     )

applyformat = ApplyMapping.apply(frame =table, mappings =
    [("field1","string","field1","string"),
    ("field2","string","field2","string") ], transformation_ctx = "applyformat")    


dfred = table.toDF().createOrReplaceTempView("table_df")

sqlDF = spark.sql(
    "SELECT COUNT(*) FROM table_df"
    )


print sqlDF.show()

job.commit()

【讨论】：