Как использовать полезную нагрузку AWS IoT в выражении Rule Engine для генерации PartitionKey

Question

Контекст проблемы: IoT AWS, подключенный к потоку данных Kinesis (KDS) с помощью AWS Rule Engine, есть опция для PartitionKey в определении правила механизма правил.PartionKey может быть заполнен с помощью выражения, такого как "$ {topic ()}".Пример полезной нагрузки сообщения:

{
    Id:"123"
    GS:"123"
}

Вопрос: Как можно определить выражение, которое использует полезную нагрузку, что-то вроде "part $ {payload (). GS}"

Answer 1

Вы можете сделать это, используя шаблон замены .

например:

{
    "rule": {
        "sql": "SELECT * FROM 'some/topic'", 
        "ruleDisabled": false, 
        "actions": [{
            "kinesis": {
                "roleArn": "arn:aws:iam::123456789012:role/aws_iot_kinesis", 
                "streamName": "my_kinesis_stream", 
                "partitionKey": "${GS}"
            }
        }], 
    }
}