Как подключиться к oracle db из лямбда-функций aws

Question

Ниже приведен код pyspark, который пытается выполнить в лямбда-функциях aws, но он вызывает ошибку и выдает указанную ошибку:

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 для успешного подключения к БД.

Спасибо

Answer 1

Вам нужно правильно включить пакеты и jar в вашу лямбда-функцию.Следуйте этому руководству https://docs.aws.amazon.com/lambda/latest/dg/lambda-python-how-to-create-deployment-package.html