APIGWV2-KDS-KDF-S3-DataGenerator.py

#!/usr/bin/python3
import requests
import datetime
import time
import threading
import random

# replace URL string with Invoke URL (APIGW V2 --> Invoke URL)
url = "https://xxxxxxxxxxxxxxxxxxxxxxxxx.amazonaws.com/beta"
for i in range(10000):
    # generating a random partition key for Kinesis Data Stream. 
    partition_key = "partition-{0}".format(random.randint(1, 1000))
    # building payload with "data" and "id" (partition key)
    myobj = {"data": "message from pixel", "id": partition_key}
    #time.sleep(1)
    x = requests.post(url, json = myobj)
    print(x.text)

Test client to send data to APIGW which further sends data to KDS ===> KDF ====> S3