mod5_Issue sending data through AWS Function

[uznab16]

I'm running into issues with my lambda function. When I test in AWS, I get the follow message:

Status: Succeeded
Test Event Name: test

Response:
{
"statusCode": 500,
"body": "{"error": "Received error: 'body'. Check the AWS Lambda logs (On the function page, navigate to 'test' then 'CloudWatch Logs Live Tail', select the log group, click start, and then run the request again to monitor the full error)"}"
}

Function Logs:
START RequestId: cf9539e4-2fc8-4b6c-9244-dbfc06287716 Version: $LATEST
{'key1': 'value1', 'key2': 'value2', 'key3': 'value3'}
'body'
File "/var/task/lambda_function.py", line 30, in lambda_handler
payload = json.loads(event["body"])

END RequestId: cf9539e4-2fc8-4b6c-9244-dbfc06287716
REPORT RequestId: cf9539e4-2fc8-4b6c-9244-dbfc06287716 Duration: 3000.00 ms Billed Duration: 3000 ms Memory Size: 128 MB Max Memory Used: 60 MB

When I use mongodb_credentials_test.py in my codespaces, I am able to connect to MongoDB fine, but I get the same error for the lambda function that I cannot figure out my way around:

Pinged your deployment. You successfully connected to MongoDB!
Inserted a test document into the horn collection.
Found the test document in the horn collection.
Deleted the test document from the horn collection.
Traceback (most recent call last):
File "/workspaces/5-data-logging-uznab16-1/mongodb_credentials_test.py", line 90, in
test_lambda_function_url()
File "/workspaces/5-data-logging-uznab16-1/mongodb_credentials_test.py", line 83, in test_lambda_function_url
response.status_code == 200
AssertionError: Received status code 502 and message Internal Server Error. Failed to add {'course_id': 'animated-giraffe'} to giraffe:horn via https://ygndu3usyaca365el7iarwchl40bxpjr.lambda-url.us-east-2.on.aws/.

If it helps, I noticed in a different thread that user cjbrew had slightly different error messages for both of these:
(1) they did not have
"File "/var/task/lambda_function.py", line 30, in lambda_handler
payload = json.loads(event["body"])" AND
(2) in their mongodb_credentials_test.py error message, they have something like "UoT_SDL_DB_Main:Tutorial Data" instead of the Function URL like I do

[sgbaird]

Could you include a link to your assignment repo?

[uznab16]

Here what happens when I use the sample lambda fxn from the tutorial:
https://github.com/user-attachments/assets/46ce42f1-8481-48d2-b587-1ab9ae8f613a

[uznab16]

Here is the error I get when I use my lambda fxn. The screen recording file is too big.

[sgbaird]

Would you mind trying to create a new lambda function from scratch per instructions in https://github.com/ACC-HelloWorld/5-data-logging#aws-lambda-function?

[uznab16]

@sgbaird I created a new lambda function from scratch per your instructions, and I still run into the same error when I run write_mongodb.py on my microcontroller.

[sgbaird]

Aside (kind of a note to self): this is what's in the notebook:

%%writefile lambda_function.py
import os
import json
from pymongo import MongoClient

username = "test-user-insert-only"

# password set as environment variable to help keep secure (even though it's
# made public in the example, i.e., to demonstrate keeping it secure)
password = os.environ.get("PASSWORD")

# atlas_uri as copy-pasted from MongoDB
atlas_uri = "mongodb+srv://<db_username>:<db_password>@test-cluster.c5jgpni.mongodb.net/?retryWrites=true&w=majority&appName=test-cluster"

# using find-replace instead of f-string to make it easier to drop-in
# the copy-pasted line above
atlas_uri = atlas_uri.replace("<db_username>", username)
atlas_uri = atlas_uri.replace("<db_password>", password)

client = MongoClient(host=atlas_uri)


def lambda_handler(event, context):
    try:
        print(event)
        payload = json.loads(event["body"])

        document = payload["document"]
        print(document)

        # You can restrict the MongoDB user to only access certain databases or
        # collections, but if you're worried about potential risk in accessing other
        # collections, an alternative to what's shown below is to hardcode the db
        # and collection names into the AWS Lambda function (as-is, it receives
        # these names)
        db_name = payload["database"]
        collection_name = payload["collection"]

        db = client[db_name]
        collection = db[collection_name]

        # Insert document
        print(f"sending document to {db_name}:{collection_name}")
        result = collection.insert_one(document)

        return {
            "statusCode": 200,
            "body": json.dumps({"message": f"Document inserted successfully to {db_name}:{collection_name} with id {result.inserted_id}"}),
        }
    except Exception as e:
        # This helps with providing some meaningful feedback instead of e.g., "Internal Server Error" when invoking the Python function
        print(e)
        return {
            "statusCode": 500,
            "body": json.dumps({"error": f"Received error: {str(e)}. Check the AWS Lambda logs (On the function page, navigate to 'test' then 'CloudWatch Logs Live Tail', select the log group, click start, and then run the request again to monitor the full error)"}),
        }

Thanks for trying from scratch. I'll go through and try to do it from scratch and see if I can reproduce the issue.