Looking for how to use this in your app?See Frontend Libraries →
Kinesis Data Streams
AWS Cloud Development Kit (AWS CDK) を使用して Amazon Kinesis Data Stream を作成し、アプリに必要なパーミッションを付与します。Amplify バックエンドにカスタム AWS リソースを追加する方法の詳細については、カスタムリソースをご覧ください。
Kinesis ストリームのセットアップ
amplify/backend.ts
import { defineBackend } from "@aws-amplify/backend";import { auth } from "./auth/resource";import { data } from "./data/resource";import { Policy, PolicyStatement } from "aws-cdk-lib/aws-iam";import { Stream } from "aws-cdk-lib/aws-kinesis";import { Stack } from "aws-cdk-lib/core";
const backend = defineBackend({ auth, data,});
const kinesisStack = backend.createStack("kinesis-stack");
// Create a Kinesis streamconst kinesisStream = new Stream(kinesisStack, "KinesisStream", { streamName: "myKinesisStream", shardCount: 1,});
// Grant PutRecords permission to authenticated usersconst kinesisPolicy = new Policy(kinesisStack, "KinesisPolicy", { statements: [ new PolicyStatement({ actions: ["kinesis:PutRecords"], resources: [kinesisStream.streamArn], }), ],});
backend.auth.resources.authenticatedUserIamRole.attachInlinePolicy(kinesisPolicy);CDK を使用していない場合は、認証済み IAM ロールに対象ストリームの kinesis:PutRecords パーミッションがあることを確認してください。
{ "Version": "2012-10-17", "Statement": [{ "Effect": "Allow", "Action": "kinesis:PutRecords", "Resource": "arn:aws:kinesis:<region>:<account-id>:stream/<stream-name>" }]}詳細については、Amazon Kinesis Developer Documentation をご覧ください。
次のステップ
Kinesis Data Streams クライアントを使用してアプリからデータをストリーミングします。