我一直在使用带有python lambda函数的AWS aurora来执行针对我们应用程序的查询。lambda函数的效果很好,但返回的结果不是前1000个,而是全部返回。我尝试通过使用分页器将限制增加到5000,找不到适合的解决方案:
import boto3
def lambda_handler(event, context):
client = boto3.client('rds-data')
readParam = event['query'] # readParam = 'select * from table;'
database1 = event['database'] # Database name
response = client.execute_sql(
awsSecretStoreArn='arn:aws:secretsmanager:us-east-1:xxxxx:secret:abc/read-XXXX',
database=database1,
dbClusterOrInstanceArn='arn:aws:rds:us-east-1:xxxxx:cluster:abcd-abc',
sqlStatements=readParam
)
return {
'statusCode': 200,
'headers': {
'Content-Type': 'application/json',
"Access-Control-Allow-Origin": "*",
"Access-Control-Allow-Headers": "Content-Type",
"Access-Control-Allow-Methods": "OPTIONS,POST"
},
'body': response
}
`
我曾尝试使用SQLAlchemy和pydataapi并将AWS开发包部署到lambda,但这是行不通的。 lambda函数无法读取具有lambda_handler的适当python文件。代码如下:
import pymysql.cursors
from sqlalchemy.engine import create_engine
def lambda_handler(event, context):
readParam = event['query']
database1 = event['database']
engine = create_engine(
'mysql+pydataapi://',
connect_args={
'resource_arn': 'arn:aws:rds:us-east-1:xxxx:cluster:abcd-abc',
'secret_arn': 'arn:aws:secretsmanager:us-east-1:xxxx:secret:abc/read-XXXX',
'database': 'mimic_dev'
}
)
result: ResultProxy = engine.execute(readParam)
return {
'statusCode': 200,
'headers': {
'Content-Type': 'application/json',
"Access-Control-Allow-Origin": "*",
"Access-Control-Allow-Headers": "Content-Type",
"Access-Control-Allow-Methods": "OPTIONS,POST"
},
'body': result.fetchall
}
我一直在尝试其他更好的解决方案吗?任何帮助表示赞赏。谢谢
此问题已解决。资源:AWS lambda deployment Package in Python
以及以下代码:
import pymysql.cursors
import json
from sqlalchemy.engine import create_engine
def lambda_handler(event,context):
engine = create_engine(
'mysql+pydataapi://',
connect_args={
'resource_arn': 'arn:aws:rds:us-east-1:xxxxx:cluster:xxxx',
'secret_arn': 'arn:aws:secretsmanager:us-east-1:xxxx:secret:decima/abcd-abc',
'database': 'mimic_dev'
}
)
result: ResultProxy = engine.execute("select * from person limit 10000")
resultValue = result.fetchall()
return json.dumps([dict(r) for r in resultValue])