kinesis

import json
import boto3

kinesis = boto3.client('kinesis')

def lambda_handler(event, context):
    
    # PutRecord API Example
    # ---------------------
    
    # Input
    record1 = {"personId": 1}

    # API Call
    response = kinesis.put_record(
        StreamName="TestStream",                    #   - name of your kinesis data stream
        Data=json.dumps(record1),                   #   - byte string input
        PartitionKey="1")                           #   - used as input to hash function to determine which shard to put the record onto
        # optional - ExplicitHashKey='string',          - ensures the record you are writing lands on a specific shard
        # optional - SequenceNumberForOrdering='string' - ensures records written serially are processed in order
        # documentation - https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/kinesis.html#Kinesis.Client.put_record