Add cfnresponse

src/cfnresponse.py

@@ -0,0 +1,55 @@
+# DO NOT EDIT
+# Source: https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/cfn-lambda-function-code-cfnresponsemodule.html#cfn-lambda-function-code-cfnresponsemodule-source-python
+
+from __future__ import print_function
+import urllib3  # type: ignore
+import json
+
+SUCCESS = "SUCCESS"
+FAILED = "FAILED"
+
+http = urllib3.PoolManager()
+
+
+def send(
+    event,
+    context,
+    responseStatus,
+    responseData,
+    physicalResourceId=None,
+    noEcho=False,
+    reason=None,
+):
+    responseUrl = event["ResponseURL"]
+
+    print(responseUrl)
+
+    responseBody = {
+        "Status": responseStatus,
+        "Reason": reason
+        or "See the details in CloudWatch Log Stream: {}".format(
+            context.log_stream_name
+        ),
+        "PhysicalResourceId": physicalResourceId or context.log_stream_name,
+        "StackId": event["StackId"],
+        "RequestId": event["RequestId"],
+        "LogicalResourceId": event["LogicalResourceId"],
+        "NoEcho": noEcho,
+        "Data": responseData,
+    }
+
+    json_responseBody = json.dumps(responseBody)
+
+    print("Response body:")
+    print(json_responseBody)
+
+    headers = {"content-type": "", "content-length": str(len(json_responseBody))}
+
+    try:
+        response = http.request(
+            "PUT", responseUrl, headers=headers, body=json_responseBody
+        )
+        print("Status code:", response.status)
+
+    except Exception as e:
+        print("send(..) failed executing http.request(..):", e)

src/unsubscriber.py

@@ -4,7 +4,7 @@
 from typing import Optional, TypedDict
 
 import boto3  # type: ignore
-import cfnresponse  # type: ignore
+from . import cfnresponse
 
 level = os.getenv("log_level", "INFO")
 logging.basicConfig(level=level)