Lambda(node.js v20)でAmazon Kinesis データストリームにプットする

Lambda(node.js v20)でAmazon Kinesis データストリームにプットする

Amazon kinesis データストリーム作成

Amazon Kinesis データストリームを作成します。

一時的に使うだけなので「オンデマンド」にします。

Lambda(node.js v20)作成

Lambdaをnode.jsで作成します。

index.mjs

import { KinesisClient, PutRecordCommand } from '@aws-sdk/client-kinesis';

const kinesisClient = new KinesisClient({ region: 'ap-northeast-1' }); 

export const handler = async (event) => {
    const data = {
        message: "Hello, World!!!",
        timestamp: new Date().toISOString()
    }; // 今回は固定値

    const params = {
        Data: JSON.stringify(data), // JSONオブジェクトを文字列化
        PartitionKey: 'hoge1', // パーティションキー
        StreamName: 'test-stream' // ストリーム名を指定
    };

    try {
        const command = new PutRecordCommand(params);
        const result = await kinesisClient.send(command);
        console.log('Data sent to Kinesis:', result);
    } catch (error) {
        console.error('Error sending data to Kinesis:', error);
    }
};

マネジメントコンソールから「テスト」します。

kinesis データストリームのシャードにデータがプットされていることが確認できます。

高橋

KHI入社して退社。今はCONFRAGEで正社員です。関西で140-170/80～120万から受け付けております^^
得意技はJS(ES20xx),Java,AWSの大体のリソースです
コメントはやさしくお願いいたします^^
座右の銘は、「狭き門より入れ」「願わくは、我に七難八苦を与えたまえ」です^^