AWSGlue:在作业启动时无法下载Snowflake连接器。
创始人
2024-09-25 18:31:47
0

可以尝试手动添加Snowflake连接器的依赖项,以防止在作业启动时无法下载。下面是添加该依赖项的示例代码:

import sys
from awsglue.utils import getResolvedOptions
from awsglue.dynamicframe import DynamicFrame
from awsglue.context import GlueContext

glue_context = GlueContext(SparkContext.getOrCreate())
args = getResolvedOptions(sys.argv, ['JOB_NAME'])

sc = SparkContext.getOrCreate()
sc._jsc.hadoopConfiguration().set("fs.s3.awsAccessKeyId", "")
sc._jsc.hadoopConfiguration().set("fs.s3.awsSecretAccessKey", "")

# 添加Snowflake连接器依赖项
sc._jvm.com.databricks.addons.SnowflakeInitiator().initializeSparkSession(sc._jvm.org.apache.spark.sql.SparkSession.builder().getOrCreate())

dynamic_frame = DynamicFrame.from_options(connection_type="snowflake", connection_options={
        "sfUrl": "",
        "sfUser": "",
        "sfPassword": "",
        "sfDatabase": "",
        "sfSchema": "",
        "sfWarehouse": ""
}, transformation_ctx="snowflake_output")

glue_context.write_dynamic_frame.from_options(frame = dynamic_frame, connection_type="s3", connection_options={
        "path": "s3://",
        "partitionKeys": [""]
}, format = "csv", transformation_ctx="s3_output")

job.commit()

在代码中,使用以下行添加Snowflake连接器依赖项:

sc._jvm.com.databricks.addons.SnowflakeInitiator().initializeSparkSession(sc._jvm.org.apache.spark.sql.SparkSession.builder().getOrCreate())

此外,还需要在代码中使用包含AWS凭证的密钥对访问S3。 在您的代码中使用您自己的访问凭证。

相关内容

热门资讯

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