Как получить ответ от AWS Python Lambda - PullRequest
0 голосов
/ 20 февраля 2020

Я написал некоторый python код, который я запускаю в AWS Lambda. Когда я тестирую Lambda на панели управления Lambda AWS и она работает без ошибок, я вижу следующее на вкладке «Результаты выполнения»:

Response: null
Request ID: "421fd7da-20f7-4029-aa8b-f7281e7c90d9"

Если при запуске Lambda I возникают ошибки см. JSON форматированный вывод на вкладке «Результаты выполнения».

Вот пример:

Response:
{
  "errorMessage": "An error occurred (DBClusterNotFoundFault) when calling the CreateDBClusterSnapshot operation: DBCluster not found: ernie-export-test-db-clusterr",
  "errorType": "DBClusterNotFoundFault",
  "stackTrace": [
    "  File \"/var/task/lambda_function.py\", line 90, in main\n    response = create_snapshot(rds, snaptype, datestamp, deleteAfterDate)\n",
    "  File \"/var/task/lambda_function.py\", line 33, in create_snapshot\n    'Value': deleteafterdate\n",
    "  File \"/var/runtime/botocore/client.py\", line 272, in _api_call\n    return self._make_api_call(operation_name, kwargs)\n",
    "  File \"/var/runtime/botocore/client.py\", line 576, in _make_api_call\n    raise error_class(parsed_response, operation_name)\n"
  ]
}

Как я могу вернуть этот «Ответ» обратно в мой код Python так Я могу использовать это / читать это? В частности, я хочу прочитать «errorMessage», чтобы мой код python в Lambda мог распечатать его или переслать - скажем, использовать в SNS.

Я добавил возврат с ответом но его содержимое не совпадает с тем, что содержится в ответе, который я получаю на вкладке «Результаты выполнения».

Вот мой код Python -

from __future__ import print_function
from boto3 import client
import datetime
from datetime import datetime

# Database cluster identifier that the backup will be performed on
CLUSTER_ID = "export-test-db-cluster"

# Name of the company that the script is used on
COMPANY = "Test"

# AWS region in which the db instances exist
REGION = "us-east-1"


def create_snapshot(rds, snaptype, datestamp, deleteafterdate):
    snapname = COMPANY + "-" + snaptype + "-" + datestamp
    response = rds.create_db_cluster_snapshot(
        DBClusterSnapshotIdentifier=snapname,
        DBClusterIdentifier=CLUSTER_ID,
        Tags=[
            {
                'Key': 'Name',
                'Value': snapname
            },
            {
                'Key': 'expirationDate',
                'Value': deleteafterdate
            },
        ]
    )
    return response


def main(event, context):
    rds = client("rds", region_name=REGION)
    now = datetime.now()
    # Should we leave time in the name?
    datestamp = now.strftime("%m-%d-%Y-%H-%M-%S")
    snaptype = "TestBackup"
    deleteAfterDate = "Today-test"
    create_snapshot(rds, snaptype, datestamp, deleteAfterDate)

Любая помощь приветствуется !!

1 Ответ

0 голосов
/ 21 февраля 2020

Должно быть что-то вроде этого.

from __future__ import print_function
from boto3 import client
import datetime
from datetime import datetime

# Database cluster identifier that the backup will be performed on
CLUSTER_ID = "export-test-db-cluster"

# Name of the company that the script is used on
COMPANY = "Test"

# AWS region in which the db instances exist
REGION = "us-east-1"


def create_snapshot(rds, snaptype, datestamp, deleteafterdate):
    snapname = COMPANY + "-" + snaptype + "-" + datestamp
    try:
        response = rds.create_db_cluster_snapshot(
            DBClusterSnapshotIdentifier=snapname,
            DBClusterIdentifier=CLUSTER_ID,
            Tags=[
                {
                    'Key': 'Name',
                    'Value': snapname
                },
                {
                    'Key': 'expirationDate',
                    'Value': deleteafterdate
                },
            ]
        )
    except Exception as e:
        response = e
        pass
    return response


def main(event, context):
    rds = client("rds", region_name=REGION)
    now = datetime.now()
    # Should we leave time in the name?
    datestamp = now.strftime("%m-%d-%Y-%H-%M-%S")
    snaptype = "TestBackup"
    deleteAfterDate = "Today-test"
    my_response = create_snapshot(rds, snaptype, datestamp, deleteAfterDate)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...