首页 > 解决方案 > 如何从 aws lambda 函数连接到 oracle db

问题描述

我在 pyspark 代码下面尝试在 aws Lambda 函数中执行,但它失败并抛出提到的错误:

from pyspark.sql import SparkSession
def lambda_handler(event, context):
    qry1DF = spark.read.format('jdbc').options(url=myjdbcUrl, dbtable="(select * from emp) qry1alias", driver="oracle.jdbc.driver.OracleDriver").load()
qry1DF.write.format("csv").option("header", "true").save("s3://mybucket/test/Lambda_test_259")

错误:无法导入模块“ lambda_function”:没有名为“ pyspark”的模块

另外我需要设置ojdbc7.jar这个来连接到oracle db,我怎样才能解决上面的错误消息以及如何设置jar文件来成功连接到db。

谢谢

标签: amazon-web-servicesjdbcpysparkaws-lambda

解决方案


推荐阅读