- Más nuevo
- Más votos
- Más comentarios
Looks like this is supported. It's just not in the docs. It works like the partition key path from the event bridge rule.
If I set the partition key to $.partitionKey
, then it would look at the incoming event and pull out the partitionKey from the source stream.
This can be accomplished by JSONPath .
Concretely, we will set a JSONPath for the partitionKey parameter (e.g $.data.customPK)
Then, when sending a payload to Pipes, on each payload they will add the partitionKey they want to shard to at the path customPk
E.g if they send { "customPK": "key1" },{ "customPK": "key2" },{ "customPK": "key3" } to the kinesis source, then the first event will be sent to partitionKey "key1", the second will be sent to "key2", and the third will be sent to "key3".
Please refer to the document : https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-input-transformation.html
Contenido relevante
- OFICIAL DE AWSActualizada hace 3 años
- OFICIAL DE AWSActualizada hace 6 meses
- OFICIAL DE AWSActualizada hace 6 meses
- OFICIAL DE AWSActualizada hace 6 meses