Connect OpenAI prompt and AWS DynamoDB in our serverless environment

class OpenaiSourceGetPromptResponse {
    async init() {
        // TODO: Create your OpenAI credential
        // More info at https://yepcode.io/docs/integrations/openai/#credential-configuration
        this.openai = yepcode.integration.openai("your-openai-credential-name");
    }

    async fetch(publish, done) {
        // TODO: Configure your prompt
        const funnyPrompts = [
            "What do you think of humans?",
            "Do you prefer tabs or spaces?",
            "What's the meaning of life, the universe, and everything?",
            "What's your favorite programming joke?",
            "What's the worst code you've ever seen?"
        ];
        // More info at: https://platform.openai.com/docs/api-reference/completions/create
        const completion = await this.openai.createCompletion({
            model: "text-davinci-003",
            prompt: funnyPrompts,
            max_tokens: 7,
            temperature: 0,
        });

        for (const choice of completion.data.choices) {
            await publish(choice);
        }
        done();
    }

    async close() {}
}

class AwsDynamodbTargetPut {
    async init() {
        // TODO: Create your aws-dynamodb credential
        // More info at https://yepcode.io/docs/integrations/aws-dynamodb/#credential-configuration
        this.awsDynamodb = yepcode.integration.awsDynamodb(
            "your-aws-dynamodb-credential-name"
        );
    }

    async consume(item) {
        // TODO: Customize the command to be executed
        // More info at: https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-dynamodb/interfaces/putitemcommandinput.html
        const putItemCommand = new PutItemCommand({
            TableName: "table-name",
            Item: {
                "table-primary-key-name": {
                    S: item.id
                },
                email: {
                    S: item.email
                },
                age: {
                    N: item.age
                },
                // etc
            },
        });

        await this.awsDynamodb.send(putItemCommand);
    }

    async close() {}
}