Membuat Fungsi Lambda untuk Tujuan Aplikasi

Aplikasi Kinesis Data Analytics Anda dapat AWS Lambda menggunakan fungsi sebagai output. Kinesis Data Analytics menyediakan templat untuk membuat fungsi Lambda yang digunakan sebagai tujuan aplikasi Anda. Gunakan templat ini sebagai titik awal untuk pasca-pemrosesan output dari aplikasi Anda.

Membuat Tujuan Fungsi Lambda di Node.js

Templat berikut untuk membuat fungsi Lambda tujuan di Node.js tersedia di konsol:

Lambda sebagai Cetak Biru Output	Bahasa dan Versi	Deskripsi
kinesis-analytics-output	Node.js 12.x	Kirimkan catatan output dari aplikasi Kinesis Data Analytics ke tujuan khusus.

Membuat Tujuan Fungsi Lambda di Python

Templat berikut untuk membuat fungsi Lambda tujuan di Phyton tersedia di konsol:

Lambda sebagai Cetak Biru Output	Bahasa dan Versi	Deskripsi
kinesis-analytics-output-sns	Python 2.7	Mengirimkan catatan keluaran dari aplikasi Kinesis Data Analytics ke AmazonSNS.
kinesis-analytics-output-ddb	Python 2.7	Kirimkan catatan output dari aplikasi Kinesis Data Analytics ke Amazon DynamoDB.

Membuat Tujuan Fungsi Lambda di Java

Untuk membuat fungsi Lambda tujuan di Java, gunakan kelas peristiwa Java.

Kode berikut menunjukkan fungsi Lambda tujuan sampel menggunakan Java:

public class LambdaFunctionHandler
        implements RequestHandler<KinesisAnalyticsOutputDeliveryEvent, KinesisAnalyticsOutputDeliveryResponse> {

    @Override
    public KinesisAnalyticsOutputDeliveryResponse handleRequest(KinesisAnalyticsOutputDeliveryEvent event,
            Context context) {
        context.getLogger().log("InvocatonId is : " + event.invocationId);
        context.getLogger().log("ApplicationArn is : " + event.applicationArn);

        List<KinesisAnalyticsOutputDeliveryResponse.Record> records = new ArrayList<KinesisAnalyticsOutputDeliveryResponse.Record>();
        KinesisAnalyticsOutputDeliveryResponse response = new KinesisAnalyticsOutputDeliveryResponse(records);

        event.records.stream().forEach(record -> {
            context.getLogger().log("recordId is : " + record.recordId);
            context.getLogger().log("record retryHint is :" + record.lambdaDeliveryRecordMetadata.retryHint);
            // Add logic here to transform and send the record to final destination of your choice.
            response.records.add(new Record(record.recordId, KinesisAnalyticsOutputDeliveryResponse.Result.Ok));
        });
        return response;
    }

}

Membuat Tujuan Fungsi Lambda di. NET

Untuk membuat fungsi Lambda tujuan di. NET, gunakan. NETkelas acara.

Kode berikut menunjukkan fungsi Lambda tujuan sampel menggunakan C#:

public class Function
    {
        public KinesisAnalyticsOutputDeliveryResponse FunctionHandler(KinesisAnalyticsOutputDeliveryEvent evnt, ILambdaContext context)
        {
            context.Logger.LogLine($"InvocationId: {evnt.InvocationId}");
            context.Logger.LogLine($"ApplicationArn: {evnt.ApplicationArn}");

            var response = new KinesisAnalyticsOutputDeliveryResponse
            {
                Records = new List<KinesisAnalyticsOutputDeliveryResponse.Record>()
            };

            foreach (var record in evnt.Records)
            {
                context.Logger.LogLine($"\tRecordId: {record.RecordId}");
                context.Logger.LogLine($"\tRetryHint: {record.RecordMetadata.RetryHint}");
                context.Logger.LogLine($"\tData: {record.DecodeData()}");

                // Add logic here to send to the record to final destination of your choice.

                var deliveredRecord = new KinesisAnalyticsOutputDeliveryResponse.Record
                {
                    RecordId = record.RecordId,
                    Result = KinesisAnalyticsOutputDeliveryResponse.OK
                };
                response.Records.Add(deliveredRecord);
            }
            return response;
        }
    }

Untuk informasi lebih lanjut tentang membuat fungsi Lambda untuk pra-pemrosesan dan tujuan di. NET, lihat Amazon.Lambda.KinesisAnalyticsEvents.