Implementing a sports analytics platform using AWS Kinesis for live data streaming, Lambda for processing, and QuickSight for visualization

Here's a simple Pulumi program using AWS Kinesis, Lambda, and IAM. Please note that Pulumi doesn't currently support AWS QuickSight directly, so you'll need to set that up manually following AWS documentation.

This simple program sets up a Kinesis stream and a Lambda function, where the Lambda function is triggered by the Kinesis stream. The Lambda function logs the records it reads from the stream.

Pulumi program:

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

// Create an AWS resource (Kinesis Stream)
const kinesisStream = new aws.kinesis.Stream("analyticsStream", {
    shardCount: 1,
});

const lambdaRole = new aws.iam.Role("lambdaRole", {
    assumeRolePolicy: JSON.stringify({
        Version: "2012-10-17",
        Statement: [
            {
                Action: "sts:AssumeRole",
                Principal: {
                    Service: "lambda.amazonaws.com",
                },
                Effect: "Allow",
                Sid: "",
            },
        ],
    }),
});

new aws.iam.RolePolicyAttachment("lambdaFullAccess", {
    role: lambdaRole.name,
    policyArn: "arn:aws:iam::aws:policy/AWSLambdaFullAccess",
});

const lambdaFunction = new aws.lambda.Function("processorFunction", {
    code: new pulumi.asset.AssetArchive({
        ".": new pulumi.asset.FileArchive("./path_to_your_code"),  // update this path to your code directory
    }),
    handler: "index.handler",  // update this path to your handler function
    runtime: aws.lambda.NodeJS12dXRuntime,
    role: lambdaRole.arn,
    environment: {
        variables: {
            STREAM_NAME: kinesisStream.name,
        },
    },
});


// Output the name of the stream
export const streamName = kinesisStream.name;
export const lambdaRoleArn = lambdaRole.arn;

Descriptions:

kinesisStream is a Kinesis Data Stream with a single shard. Stream data, such as sports event data, can be written to this stream for processing. More about the aws.kinesis.Stream resource is here

lambdaRole is an IAM role that the Lambda function will use. I've given it the AWSLambdaFullAccess managed policy for simplicity but in a production context, you'd want to limit the Lambda function's permissions to just the actions and resources it needs.

lambdaFunction is a Lambda function. It's currently set up to use code from a local directory and a handler function at index.handler. You would replace these values with the path to your code and the path to your handler function. The function logs events it reads from the Stream to CloudWatch Logs.

Again, please note that setting up AWS QuickSight isn't possible directly through Pulumi at the moment, so you'll need to set it up manually.

Let me know if you have further questions or need elaboration!