您好，我正在尝试解析json文件在以下结构到DynamicFrame列.我需要每一列分别 changedFields|First Name|Last Name| ...... | id
浏览 24提问于2020-07-14得票数 0
1回答
从Glue DynamicFrame读取数据并将其写入RDS Postgresql实例时，Glue无法将格式为yyyy/MM/dd的日期转换为yyyy-MM-dd格式。该字段在Glue目录中被检测为类型字符串，数据库类型为date。设置日期格式为"yyyy-mm-dd“的字段。通过使用雅典娜查询编目的S3文件，我验证了源日期不为空。我尝试通过将DynamicFrame转换为Spark数据框并转换列来<em
浏览 12提问于2020-11-05得票数 1
回答已采纳
目标：我们希望使用AWS数据目录为驻留在S3桶中的JSON数据创建一个表，然后通过Redshift频谱查询和解析该表。
背景：-- JSON数据来自DynamoDB流，并且是深度嵌套的。理想情况下，我们希望使用Glue只解析第一个级别的JSON，并且基本上将较低级别作为大字符串对象(然后我们将根据需要使用Redshift谱解析这些对象)。目前，我们正在将整个记录加载到Redshift中的单个VARCHAR列中，但记录
浏览 0提问于2018-03-23得票数 23
回答已采纳
我正在尝试将一些pySpark代码转换为Scala，以提高性能。在AWS (它使用Apache )中，会自动为您生成一个脚本，它通常使用DynamicFrame对象加载、转换和写入数据。但是，DynamicFrame类并不具有与DataFrame类相同的所有功能，有时您必须将其转换回DataFrame对象，反之亦然，以执行某些操作。下面是我如何在DataFrame中将DynamicFrame对象转换为pySpark对象： /
浏览 1提问于2018-05-17得票数 3
回答已采纳
我正在为AWS编写一个ETL脚本，该脚本来源于S3存储的json文件，其中我正在创建一个DynamicFrame，并试图使用pushDownPredicate逻辑来限制输入的数据：
我是AWS Glue和Spark的新手，尽管如此，对于为什么谓词时间戳不能针对实际上包含时间戳的分区列来解析，我感到
浏览 0提问于2019-02-22得票数 2
回答已采纳
我在S3中的Json结构如下。我已经成功地将它爬行到数据目录表中，并将其导入到DynamicFrame中。Value", "Value" "ColumnC": "Value",}我
浏览 1提问于2020-04-15得票数 2
回答已采纳
headersAPI = { , 'accept': 'application/json'skill_json=sk
浏览 0提问于2021-07-27得票数 0
我在PySpark中读取AWS Glue作业的数据时遇到问题：火花遗物DataFramespark_df = spark.read.json</
浏览 1提问于2020-06-11得票数 4
回答已采纳
我在一个S3桶中有一些数据，其中包含许多json文件，这些文件看起来有点像这样：day分区包含多个但是，我想根据每个文件的分区创建一个包含hour值的新列。我可以使用Spark创建一个带有常量的新列，但是如何使这个列使用分区作为源呢？df1 = dynamicFrame.toDF().withColumn("u
浏览 2提问于2019-04-30得票数 3
回答已采纳
1回答
当我运行胶水作业时，它会失败，例外情况是“不知道如何将NullType保存为REDSHIFT”。我不完全理解为什么，但我能收集到的最好结果是，DynamicFrame
浏览 4提问于2017-11-28得票数 5
2回答
胶水作业模式推理问题
、、、、
请求：我需要一个胶水作业将aws(嵌套结构-映射和列表的组合)数据导入s3。我的输入dataframe df0以struct格式包含json数据collection，因此我使用to_json将struct转换为json-string在这里，我需要json字符串，而不是结构。
df1 = df0.select(to_json</
浏览 3提问于2020-08-24得票数 0
回答已采纳
1回答
正在导入字符串/varchar列，但不导入数字列。下面是postgres rds列类型：下面是python胶水脚本： dynamicFrame_dept_summary = self.glueContext.create_dynamic_frame.from_options],
"
浏览 6提问于2022-12-02得票数 0
我有一个数据列的数据集。该列通常为'dd/MM/yy‘格式，但有时它有垃圾文本。我希望最终将列转换为日期，并将垃圾文本作为空值。
我一直试图使用resolveChoice，但是它导致了所有的空值。
浏览 0提问于2019-05-23得票数 0
我有一个比varchar(max)数据类型更大的列，据我所知，varchar(Max)数据类型是AWS Glue使用的最大数据类型，因此当我尝试加载我的表时，收到错误消息"String length exceeds我并不是要截断这一列，因为它并不那么重要，并且不知道如何在Glue中做到这一点。但是，我的老板坚持让我使用Glue来完成这项工作，所以我正在寻找一种使用Glue脚本截断列的方法。我查阅了很多文档，但找不到类似的东西。谢谢。请注意，varchar(65535)是一列在Redshift中可以包含的最大字符数
浏览 22提问于2018-08-02得票数 0
回答已采纳
1回答
AWS胶排除模式
、、、
这是使用将数据从S3桶读取到DynamicFrame的方法，使用recurse连接选项设置为True，因为数据是大量嵌套的。我只希望读取以meta.json结尾的文件，因此我已经将设置为排除以data.csv "exclusions": ['**.Unable to parse file: <filename>.data.csv
是否可以将完整的S3 uri记录到输出日志，或者跟踪已经/尚未处理的文件？它仍然试图解析这
浏览 12提问于2022-02-24得票数 0
回答已采纳
如何将resolveChoice应用于DynamicFrame中数组中的struct元素？用于参考的DynamicFrame模式|-- ColumnB: array| | |-- ColumnC| | |-- ColumnD: choice| | | |-- int
我想将resolveChoice应用于D列。
浏览 4提问于2020-04-20得票数 1
我正在尝试用JDBC写在一个AWSGlue数据库中编写一个DynamicFrame。目标表包含一个类型为Enum的列。首先从基础PySpark DataFrame中选择感兴趣的列，然后将DataFrame转换为DynamicFrame：final_df = df.select("id", "my_struct.*")
# Convert back to DynamicFrame<
浏览 3提问于2021-12-09得票数 0
在AWS S3中，我使用AWS的create_dynamic_frame.from_options("s3" ...)读取json文档，DynamicFrame.printSchema()向我展示了这一点() (已经尝试了这两种方法)将DynamicFrame转换成一个新的dyF，然后.printSchema()向我展示了这一点，这似乎是不嵌套的：|-- updatedAt: string|-- json.rowId: int
问题是，我似乎不能使用嵌套字段。dyF.sel
浏览 2提问于2021-09-02得票数 2
回答已采纳
1回答
将JSON列解析为
、、、
我有这个数据： item = c("Box 1", "Tape", "Pen"), json = c("tape color"}', ) item length json, "color": &q
浏览 5提问于2022-02-04得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
