In Android Studio im writing in Kotlin, and i have a string which is the users input. its called userPromptvc. I am calling my function URL with my http client and i have a json payload that is not being used. id like to pass this string as an event and retrieve it in my aws lambda function to use the userPromptvc as my prompt. Please help update my code in order to do this.

Here is my Android studio code in Kotlin:

Thread { // taking user input, and changing the lambda function to process it val userPromptvc = inputFieldvc.text.toString()

                // below is letting our Lambda Function Env Var take a second to update
                try {
                    Thread.sleep(1000)  // Sleep (block) the current thread for 3 seconds
                } catch (e: InterruptedException) {
                    e.printStackTrace()  // Handle potential interruption
                }

                // then we will go ahead and invoke it now that its done updating with user input.
               // invokeLambdaNova()
                // invoke lambda actual function code below for testing
                //Log.d("LambdaInvokeNova", "Starting invokeLambda()")

                val client = OkHttpClient.Builder()
                    .connectTimeout(30, TimeUnit.SECONDS)
                    .readTimeout(30, TimeUnit.SECONDS)
                    .writeTimeout(30, TimeUnit.SECONDS)
                    .build()
                Log.d("LambdaInvokeNova", "OkHttpClient created")

                val url = "https://dwyrc3i6pgmugzzdqtkczq2lza0ohpek.lambda-url.us-east-1.on.aws/"
                val jsonPayload = "{\"key1\":\"value1\", \"key2\":\"value2\"}"
                Log.d("LambdaInvokeNova", "Payload prepared: $jsonPayload")

                val requestBody = jsonPayload.toRequestBody("application/json".toMediaType())
                Log.d("LambdaInvokeNova", "Request body created")

                val request = Request.Builder()
                    .url(url)
                    .post(requestBody)
                    .build()
                Log.d("LambdaInvokeNova", "Request built: $request")

Here is my AWS Lambda Function code:

import json import boto3 import os

Create the Bedrock Runtime client.

bedrock_runtime = boto3.client("bedrock-runtime")

def lambda_handler(event, context): model_input = { "taskType": "TEXT_VIDEO", "textToVideoParams": { "text": json.loads(os.environ['NOVAPROMPT']) }, "videoGenerationConfig": { "durationSeconds": 6, "fps": 24, "dimension": "1280x720", "seed": 33, # Change the seed to get a different result }, } try: # Start the asynchronous video generation job. invocation = bedrock_runtime.start_async_invoke( modelId="amazon.nova-reel-v1:1", modelInput=model_input, outputDataConfig={ "s3OutputDataConfig": { "s3Uri": "s3://novabucket" } } )

    # Extract the S3 object key from the response.
   # s3_object_key = invocation.get('outputDataConfig', {}).get('s3OutputDataConfig', {}).get('s3Uri', '').split('/')[-1]

   
     # Extract the invocation ID from the invocationArn
    invocation_id = invocation['invocationArn'].split('/')[-1]
    
    # Construct the future object key
    future_object_key = f"{invocation_id}/output.mp4"


    # Return the object key along with other details.
    return {
        "statusCode": 200,
        "body": json.dumps({
            "invocationArn": invocation.get('invocationArn'),
            "requestId": invocation.get('requestId'),
            "futureObjectKey": f"{invocation_id}/output.mp4"
            #future_object_key
        })
    }

except Exception as e:
    # Implement error handling here.
    message = e.response["Error"]["Message"]
    return {
        "statusCode": 500,
        "body": json.dumps({"error": message})
    }