{ "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') }