#!/usr/bin/env python3
import json
import requests

HOST = "localhost"
PORT = "9000"

LAMBDA_URL = f"http://{HOST}:{PORT}/2015-03-31/functions/function/invocations"

payload = {
    "Records": [
        {
            "body": json.dumps(
                {
                    "task_id": "ea1a20b2-a21f-464c-9999-25f684405b69",
                    "sub_task_id": "747c99df-a1ff-41a0-98c2-5265d7797f90",
                    "s3_uri": "s3://retrofit-data-dev/ara_raw_outputs/hyde/output1(Sheet2).csv",
                    "lexiscore_column": "address2uprn_lexiscore",
                    "lexiscore_threshold": 0.2,
                }
            )
        }
    ]
}

response = requests.post(LAMBDA_URL, json=payload)

print("Status code:", response.status_code)
print("Response:")
print(response.text)