{
"StreamName": "api-kds",
"Data": "$util.base64Encode($input.body)",
"PartitionKey": "$context.requestId"
}
{
"StreamName": "$input.params('stream')"
}





{
"stream-name": "$input.params('stream')",
"shard-count": $input.json('$.StreamDescriptionSummary.OpenShardCount')
}
