aws.dynamodb.KinesisStreamingDestination

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

const example = new aws.dynamodb.Table("example", {
    name: "orders",
    hashKey: "id",
    attributes: [{
        name: "id",
        type: "S",
    }],
});
const exampleStream = new aws.kinesis.Stream("example", {
    name: "order_item_changes",
    shardCount: 1,
});
const exampleKinesisStreamingDestination = new aws.dynamodb.KinesisStreamingDestination("example", {
    streamArn: exampleStream.arn,
    tableName: example.name,
});

import pulumi
import pulumi_aws as aws

example = aws.dynamodb.Table("example",
    name="orders",
    hash_key="id",
    attributes=[{
        "name": "id",
        "type": "S",
    }])
example_stream = aws.kinesis.Stream("example",
    name="order_item_changes",
    shard_count=1)
example_kinesis_streaming_destination = aws.dynamodb.KinesisStreamingDestination("example",
    stream_arn=example_stream.arn,
    table_name=example.name)

package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/dynamodb"
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/kinesis"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := dynamodb.NewTable(ctx, "example", &dynamodb.TableArgs{
			Name:    pulumi.String("orders"),
			HashKey: pulumi.String("id"),
			Attributes: dynamodb.TableAttributeArray{
				&dynamodb.TableAttributeArgs{
					Name: pulumi.String("id"),
					Type: pulumi.String("S"),
				},
			},
		})
		if err != nil {
			return err
		}
		exampleStream, err := kinesis.NewStream(ctx, "example", &kinesis.StreamArgs{
			Name:       pulumi.String("order_item_changes"),
			ShardCount: pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		_, err = dynamodb.NewKinesisStreamingDestination(ctx, "example", &dynamodb.KinesisStreamingDestinationArgs{
			StreamArn: exampleStream.Arn,
			TableName: example.Name,
		})
		if err != nil {
			return err
		}
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() => 
{
    var example = new Aws.DynamoDB.Table("example", new()
    {
        Name = "orders",
        HashKey = "id",
        Attributes = new[]
        {
            new Aws.DynamoDB.Inputs.TableAttributeArgs
            {
                Name = "id",
                Type = "S",
            },
        },
    });

    var exampleStream = new Aws.Kinesis.Stream("example", new()
    {
        Name = "order_item_changes",
        ShardCount = 1,
    });

    var exampleKinesisStreamingDestination = new Aws.DynamoDB.KinesisStreamingDestination("example", new()
    {
        StreamArn = exampleStream.Arn,
        TableName = example.Name,
    });

});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.dynamodb.Table;
import com.pulumi.aws.dynamodb.TableArgs;
import com.pulumi.aws.dynamodb.inputs.TableAttributeArgs;
import com.pulumi.aws.kinesis.Stream;
import com.pulumi.aws.kinesis.StreamArgs;
import com.pulumi.aws.dynamodb.KinesisStreamingDestination;
import com.pulumi.aws.dynamodb.KinesisStreamingDestinationArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var example = new Table("example", TableArgs.builder()
            .name("orders")
            .hashKey("id")
            .attributes(TableAttributeArgs.builder()
                .name("id")
                .type("S")
                .build())
            .build());

        var exampleStream = new Stream("exampleStream", StreamArgs.builder()
            .name("order_item_changes")
            .shardCount(1)
            .build());

        var exampleKinesisStreamingDestination = new KinesisStreamingDestination("exampleKinesisStreamingDestination", KinesisStreamingDestinationArgs.builder()
            .streamArn(exampleStream.arn())
            .tableName(example.name())
            .build());

    }
}

resources:
  example:
    type: aws:dynamodb:Table
    properties:
      name: orders
      hashKey: id
      attributes:
        - name: id
          type: S
  exampleStream:
    type: aws:kinesis:Stream
    name: example
    properties:
      name: order_item_changes
      shardCount: 1
  exampleKinesisStreamingDestination:
    type: aws:dynamodb:KinesisStreamingDestination
    name: example
    properties:
      streamArn: ${exampleStream.arn}
      tableName: ${example.name}

var kinesisStreamingDestinationResource = new Aws.DynamoDB.KinesisStreamingDestination("kinesisStreamingDestinationResource", new()
{
    StreamArn = "string",
    TableName = "string",
});

example, err := dynamodb.NewKinesisStreamingDestination(ctx, "kinesisStreamingDestinationResource", &dynamodb.KinesisStreamingDestinationArgs{
	StreamArn: pulumi.String("string"),
	TableName: pulumi.String("string"),
})

var kinesisStreamingDestinationResource = new KinesisStreamingDestination("kinesisStreamingDestinationResource", KinesisStreamingDestinationArgs.builder()
    .streamArn("string")
    .tableName("string")
    .build());

kinesis_streaming_destination_resource = aws.dynamodb.KinesisStreamingDestination("kinesisStreamingDestinationResource",
    stream_arn="string",
    table_name="string")

const kinesisStreamingDestinationResource = new aws.dynamodb.KinesisStreamingDestination("kinesisStreamingDestinationResource", {
    streamArn: "string",
    tableName: "string",
});

type: aws:dynamodb:KinesisStreamingDestination
properties:
    streamArn: string
    tableName: string