Trade-offs in AWS Lambda

import json
import time
from google.api_core.exceptions import PreconditionFailed
from google.cloud import storage

def handler(event, context):
    job_id = event["job_id"]
    if job_id not in {"image-1001", "image-1002"}:
        raise ValueError("Only this trial's job IDs are accepted")
    payload = json.dumps({"job_id": job_id, "result": "thumbnail-ok"},
                         sort_keys=True).encode()
    blob = storage.Client().bucket("acme-adapter-trial-results").blob(
        "tradeoff/" + job_id + ".json")
    try:
        blob.upload_from_string(payload, content_type="application/json",
                                if_generation_match=0)
    except PreconditionFailed:
        if blob.download_as_bytes() != payload:
            raise ValueError("Job ID already has a different result")
    time.sleep(min(float(event.get("delay_after_write", 0)), 10))
    return {"job_id": job_id, "object": blob.name}

tensor9 explain \
  -origin aws::1.0.0::lambda::function \
  -target google::1.0.0::cloud-run \
  -operation Invoke -fmt Human

export AWS_ENDPOINT_URL_LAMBDA="<test adapter endpoint>"
export AWS_PROFILE="adapter-test"
export AWS_REGION="us-east-1"

aws lambda invoke \
  --function-name tradeoff-thumbnail \
  --invocation-type RequestResponse \
  --cli-binary-format raw-in-base64-out \
  --payload '{"job_id":"image-1001"}' \
  thumbnail-first.json

gcloud storage cat gs://acme-adapter-trial-results/tradeoff/image-1001.json

import json
import boto3
from botocore.config import Config
from botocore.exceptions import ReadTimeoutError

client = boto3.client("lambda", region_name="us-east-1",
    endpoint_url="<test adapter endpoint>",
    config=Config(read_timeout=1, retries={"total_max_attempts": 1}))
try:
    response = client.invoke(FunctionName="tradeoff-thumbnail",
        InvocationType="RequestResponse",
        Payload=json.dumps({"job_id": "image-1002",
                            "delay_after_write": 5}).encode())
    print(response["Payload"].read())
except ReadTimeoutError:
    print("Caller timed out; inspect the target before retrying")