AWSGlue:Anerroroccurredwhilecallingo100.pyWriteDynamicFrame.Failedtofinddatasource:UNKNOWN
创始人
2024-09-25 14:31:55
0

该问题通常是由于在AWS Glue作业中使用的数据源未被正确识别,因此需要确保所使用的数据源被正确识别。一个可能的解决方法是使用正确的数据源类型和相应的依赖项。下面是一个Python代码示例,可以用于指定正确的数据源类型:

from awsglue.context import GlueContext from pyspark.context import SparkContext from pyspark.sql.functions import * from awsglue.transforms import * from awsglue.dynamicframe import *

sc = SparkContext.getOrCreate() glueContext = GlueContext(sc) spark = glueContext.spark_session

创建DynamicFrame对象,输入数据源和数据格式

dynamic_frame = glueContext.create_dynamic_frame.from_options( connection_type="s3", connection_options={ "path": "s3://bucket/path/to/file", "format": "json" }, format="json" )

执行转换操作

...

保存结果到输出数据源

如果使用的是S3数据源,则需要在connection_options中指定S3区域

dynamic_frame.write.format('parquet').save('s3://output-bucket/output-dir',
connection_options={"region": "us-west-2"})

相关内容

热门资讯

第六分钟透视!微乐小程序游戏破... 第六分钟透视!微乐小程序游戏破解器(辅助挂)原来是有挂(普及教程开挂辅助神器);无需打开直接搜索薇:...
5分钟发现!广西友乐解码器下载... 5分钟发现!广西友乐解码器下载安装(辅助挂)果然是有挂(介绍教程开挂辅助安装) 了解更多开挂安装加(...
第六分钟科普!湖北休闲辅助(辅... 第六分钟科普!湖北休闲辅助(辅助挂)一直确实有挂(安装教程开挂辅助神器)1、下载安装好湖北休闲辅助,...
第二分钟辅助!至余干辅助(辅助... 第二分钟辅助!至余干辅助(辅助挂)其实确实有挂(教你攻略开挂辅助平台) >>您好:软件加薇13670...
7分钟辅助!仟众部落辅助(辅助... 7分钟辅助!仟众部落辅助(辅助挂)其实确实有挂(德州论坛开挂辅助平台);亲,仟众部落辅助这款游戏原来...
三分钟详情!玄龙辅助工具(辅助... 三分钟详情!玄龙辅助工具(辅助挂)一直确实有挂(规律教程开挂辅助软件);无需打开直接搜索微信(136...
第二分钟讲解!浙江游戏辅助(辅... 您好:浙江游戏辅助这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特别...
十分钟了解!福建天天开心福州器... 十分钟了解!福建天天开心福州器真的假的(辅助挂)原来有挂(安装教程开挂辅助安装);无需打开直接搜索加...
第6分钟科普!微信随意玩辅助器... 您好:这款微信随意玩辅助器有开挂吗游戏是可以开挂的,确实是有挂的,很多玩家在这款微信随意玩辅助器有开...
第七分钟发现!情怀游戏字牌辅助... 第七分钟发现!情怀游戏字牌辅助(辅助挂)一直真的是有挂(黑科技教程开挂辅助神器);无需打开直接搜索打...