Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Fonctions

Vous pouvez utiliser les fonctions intégrées suivantes dans les WHERE clauses SELECT ou de vos SQL expressions.

abs(Decimal)

Il renvoie la valeur absolue d'un nombre. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Par exemple, abs(-5) renvoie 5.

accountid()

Renvoie l'ID du compte qui possède la règle comme une valeur String. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

accountid() = "123456789012"

acos(Decimal)

Renvoie le cosinus inverse d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : acos(0) = 1,5707963267948966

asin(Decimal)

Renvoie le sinus inverse d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : asin(0) = 0,0

atan(Decimal)

Renvoie la tangente inverse d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : atan(0) = 0,0

atan2(Decimal, Decimal)

Il renvoie l'angle en radians, entre l'axe des X positifs et le point (x, y) défini dans les deux arguments.  L'angle est positif pour les angles sans le sens contraire des aiguilles d'une montre (moitié supérieure du plan, y > 0) et négatif pour les angles dans le sens des aiguilles d'une montre (moitié inférieure du plan, y < 0). Les arguments Decimal sont arrondis pour une meilleure précision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : atan2(1, 0) = 1,5707963267948966

aws_lambda (,) functionArn inputJson

Appelle la fonction Lambda spécifiée en passant inputJson à la fonction Lambda et renvoie le résultat généré JSON par la fonction Lambda.

Vous devez accorder AWS IoT lambda:InvokeFunction des autorisations pour appeler la fonction Lambda spécifiée. L'exemple suivant montre comment accorder l'autorisation lambda:InvokeFunction à l'aide de l' AWS CLI :

aws lambda add-permission --function-name "function_name"
--region "region"
--principal iot.amazonaws.com 
--source-arn arn:aws:iot:us-east-1:account_id:rule/rule_name
--source-account "account_id"
--statement-id "unique_id" 
--action "lambda:InvokeFunction"

Les arguments de la commande add-permission sont les suivants :

Étant donné une charge utile de JSON message comme :

{
    "attribute1": 21,
    "attribute2": "value"
}

La fonction aws_lambda peut être utilisée pour appeler la fonction Lambda, comme suit :

SELECT
aws_lambda("arn:aws:lambda:us-east-1:account_id:function:lambda_function", {"payload":attribute1}) as output FROM 'topic-filter'

Si vous souhaitez transmettre la charge utile complète du MQTT message, vous pouvez spécifier la JSON charge utile en utilisant « * », comme dans l'exemple suivant.

SELECT
aws_lambda("arn:aws:lambda:us-east-1:account_id:function:lambda_function", *) as output FROM 'topic-filter'

payload.inner.element sélectionne les données à partir des messages publiés dans la rubrique « rubrique/sous-rubrique ».

some.value sélectionne les données à partir de la sortie générée par la fonction Lambda.

bitand(Int, Int)

Effectue une opération bit par bit AND sur les représentations binaires des deux arguments Int (convertis). Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : bitand(13, 5) = 5

bitor(Int, Int)

Il effectue une opération OR au niveau du bit des représentations binaires des deux arguments. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : bitor(8, 5) = 13

bitxor(Int, Int)

Effectue une opération bit par bit XOR sur les représentations binaires des deux arguments Int (convertis). Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : bitor(13, 5) = 8

bitnot(Int)

Effectue une opération bit par bit NOT sur les représentations binaires de l'Intargument (converti). Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : bitnot(13) = 2

cast()

Convertit une valeur d'un type de données en un autre. La conversion se comporte principalement comme les conversions standard, avec en outre la capacité de convertir des chiffres vers/depuis des valeurs booléennes. Si vous AWS IoT ne pouvez pas déterminer comment convertir un type en un autre, le résultat estUndefined. Pris en charge par SQL la version 2015-10-08 et versions ultérieures. Format : fonte (valuestype).

Exemple :

cast(true as Int) = 1

Les mots-clés suivants peuvent apparaître après « as » lors de l'appel de cast :

Règles de conversion de types :

ceil(Decimal)

Arrondit la valeur Decimal donnée à la valeur Int supérieure la plus proche. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

ceil(1.2) = 2

ceil(-1.2) = -1

chr(String)

Renvoie le ASCII caractère correspondant à l'Intargument donné. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

chr(65) = "A".

chr(49) = "1".

clientid()

Renvoie l'ID du MQTT client qui envoie le message, ou n/a si le message n'a pas été envoyéMQTT. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

clientid() = "123456789012"

concat()

Concatène des tableaux ou des chaînes. Cette fonction accepte n'importe quel nombre d'arguments et renvoie une valeur String ou Array. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

concat() = Undefined.

concat(1) = "1".

concat([1, 2, 3], 4) = [1, 2, 3, 4].

concat([1, 2, 3], "hello") = [1, 2, 3, "bonjour"]

concat("con", "cat") = "concat"

concat(1, "hello") = "bonjour1"

concat("he","is","man") = "heisman"

concat([1, 2, 3], "hello", [4, 5, 6]) = [1, 2, 3, "bonjour", 4, 5, 6]

cos(Decimal)

Renvoie le cosinus d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

cos(0) = 1.

cosh(Decimal)

Renvoie le cosinus hyperbolique d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : cosh(2.3) = 5.037220649268761.

décoder (valeur,decodingScheme)

Utilisez la fonction decode pour décoder une valeur codée. Si la chaîne décodée est un JSON document, un objet adressable est renvoyé. Sinon, la chaîne décodée est renvoyée sous forme de chaîne. La fonction revient NULL si la chaîne ne peut pas être décodée. Cette fonction prend en charge le décodage des chaînes codées en base64 et du format de message Protocol Buffer (protobuf).

Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Décodage de chaînes codées en base64

Dans cet exemple, la charge utile du message inclut une valeur codée.

{
    encoded_temp: "eyAidGVtcGVyYXR1cmUiOiAzMyB9Cg=="
}

La decode fonction décrite dans cette SQL instruction décode la valeur de la charge utile du message.

SELECT decode(encoded_temp,"base64").temperature AS temp from 'topic/subtopic'

Le décodage de la encoded_temp valeur permet d'obtenir le JSON document valide suivant, qui permet à l'SELECTinstruction de lire la valeur de température.

{ "temperature": 33 }

Le résultat de l'SELECTinstruction dans cet exemple est affiché ici.

{ "temp": 33 }

Si la valeur décodée n'était pas un JSON document valide, elle serait renvoyée sous forme de chaîne.

Décodage de la charge utile des messages protobuf

Vous pouvez utiliser la SQL fonction de décodage pour configurer une règle capable de décoder la charge utile de votre message protobuf. Pour plus d’informations, veuillez consulter la section Décodage des charges utiles des messages protobuf.

La signature de la fonction ressemble à ce qui suit :

decode(<ENCODED DATA>, 'proto', '<S3 BUCKET NAME>', '<S3 OBJECT KEY>', '<PROTO NAME>', '<MESSAGE TYPE>')            

Voici un exemple SQL d'expression utilisant la SQL fonction de décodage :

SELECT VALUE decode(*, 'proto', 's3-bucket', 'messageformat.desc', 'myproto', 'messagetype') FROM 'some/topic'

encoder (valeur,encodingScheme)

Utilisez la encode fonction pour encoder la charge utile, qui peut être non une JSON donnée, dans sa représentation sous forme de chaîne basée sur le schéma de codage. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

endswith(String, String)

Renvoie une valeur Boolean indiquant si le premier argument String se termine par le deuxième argument String. Si l'un des arguments est Null ou Undefined, le résultat a la valeur Undefined. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Par exemple : endswith("cat","at") = true.

exp(Decimal)

Renvoie la valeur augmentée vers l'argument Decimal. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : exp(1) = e.

floor(Decimal)

Arrondit la valeur Decimal donnée à la valeur Int inférieure la plus proche. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

floor(1.2) = 1

floor(-1.2) = -2

get

Extrait une valeur à partir d'un type de collection (tableau, chaîne, objet). Aucune conversion n'est appliquée au premier argument. Une conversion s'applique comme documenté dans le tableau au deuxième argument. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

get(["a", "b", "c"], 1) = "b"

get({"a":"b"}, "a") = "b"

get("abc", 0) = « a ».

get_dynamodb (tableName,,,, partitionKeyName, partitionKeyValue) sortKeyName sortKeyValue roleArn

Récupère des données d’une table DynamoDB. get_dynamodb() vous permet d’interroger une table DynamoDB pendant l’évaluation d’une règle. Vous pouvez filtrer ou augmenter les charges utiles des messages à l’aide des données extraites de DynamoDB. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

get_dynamodb() accepte les paramètres suivants :

À titre d’exemple d’utilisation de get_dynamodb(), supposons que vous disposez d’une table DynamoDB contenant l’ID d’appareil et les informations d’emplacement de tous vos appareils connectés à AWS IoT. L'SELECTinstruction suivante utilise la get_dynamodb() fonction pour récupérer l'emplacement de l'identifiant de périphérique spécifié :

SELECT *, get_dynamodb("InServiceDevices", "deviceId", id, "arn:aws:iam::12345678910:role/getdynamo").location AS location FROM 'some/topic'

get_mqtt_property (nom)

Fait référence à l'un MQTT5 des en-têtes suivants :contentType, payLoadFormatIndicatorresponseTopic, etcorrelationData. Cette fonction prend l’une des chaînes littérales suivantes comme argument :content_type, format_indicator response_topic, etcorrelation_data. Pour plus d’informations, veuillez consulter la table des arguments de fonction suivante.

Le tableau suivant indique les arguments de fonction acceptables et les types de retour associés pour la fonction get_mqtt_property :

L'exemple de règles suivant SQL fait référence à l'un MQTT5 des en-têtes suivants :contentType, payLoadFormatIndicatorresponseTopic, etcorrelationData.

SELECT *, get_mqtt_property('content_type') as contentType,
          get_mqtt_property('format_indicator') as payloadFormatIndicator,
          get_mqtt_property('response_topic') as responseTopic,
          get_mqtt_property('correlation_data') as correlationData
FROM 'some/topic'

get_secret (secretId, clésecretType,) roleArn

Récupère la valeur du champ chiffré SecretString ou SecretBinary de la version actuelle d’un secret dans AWS Secrets Manager. Pour plus d'informations sur la création et la gestion de secrets CreateSecret, consultez les UpdateSecretsections, et PutSecretValue.

get_secret() accepte les paramètres suivants :

Exemples :

Vous pouvez utiliser la get_secret fonction dans un en-tête d'authentification dans le cadre d'une action de HTTPS règle, comme dans l'exemple d'authentification par API clé suivant.

"API_KEY": "${get_secret('API_KEY', 'SecretString', 'API_KEY_VALUE', 'arn:aws:iam::12345678910:role/getsecret')}"
            

Pour plus d'informations sur l'action de la HTTPS règle, consultezHTTP.

get_thing_shadow (, rôle) thingName shadowName ARN

Renvoie le shadow spécifié de l'objet spécifié. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Exemples :

Lorsqu'elle est utilisée avec un shadow nommé, fournissez le paramètre shadowName.

SELECT * from 'topic/subtopic'
WHERE
    get_thing_shadow("MyThing","MyThingShadow","arn:aws:iam::123456789012:role/AllowsThingShadowAccess")
    .state.reported.alarm = 'ON'

Lorsqu'elle est utilisée avec un shadow non nommé, omettez le paramètre shadowName.

SELECT * from 'topic/subtopic'
WHERE
    get_thing_shadow("MyThing","arn:aws:iam::123456789012:role/AllowsThingShadowAccess")
    .state.reported.alarm = 'ON'

get_user_properties () userPropertyKey

Références aux propriétés utilisateur, qui est un type d'en-tête de propriété pris en charge dansMQTT5.

Arguments de la fonction

Pour les propriétés utilisateur suivantes dans les en-têtes des messages :

Le tableau suivant indique le SQL comportement attendu :

L'exemple de règles suivant SQL fait référence aux propriétés utilisateur (un type d'en-tête de MQTT5 propriété) dans la charge utile :

SELECT *, get_user_properties('user defined property key') as userProperty
FROM 'some/topic'

Fonctions de hachage

AWS IoT fournit les fonctions de hachage suivantes :

Toutes les fonctions de hachage prévoit un argument de type chaîne. Le résultat est la valeur hachée de cette chaîne. Les conversions de chaîne standard s'appliquent aux arguments non-chaîne. Toutes les fonctions de hachage sont prises en charge par les SQL versions 2015-10-08 et ultérieures.

Exemples :

md2("hello") = "a9046c73e00331af68917d3804f70655"

md5("hello") = "5d41402abc4b2a76b9719d911017c592"

indexof(String, String)

Renvoie le premier index (de base 0) du deuxième argument comme une sous-chaîne dans le premier argument. Les deux arguments doivent être des chaînes. Les arguments qui ne sont pas des chaînes sont soumis aux règles de conversion de chaînes standard. Cette fonction ne s'applique pas aux tableaux, uniquement aux chaînes. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Exemples :

indexof("abcd", "bc") = 1

isNull()

Retourne la valeur true si la valeur de l'argument est Null. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

isNull(5) = false.

isNull(Null) = vrai.

isUndefined()

Retourne la valeur true si l'argument est Undefined. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Exemples :

isUndefined(5) = false.

isUndefined(floor([1,2,3]))) = vrai.

length(String)

Renvoie le nombre de caractères dans la chaîne fournie. Les règles de conversion standard s'appliquent aux arguments non-String. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Exemples :

length("hi") = 2

length(false) = 5

ln(Decimal)

Renvoie le logarithme naturel de l'argument Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : ln(e) = 1.

log(Decimal)

Renvoie le logarithme 10 de base de l'argument Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : log(100) = 2.0.

lower(String)

Renvoie la version en minuscules de la valeur de String donnée. Les arguments non-chaîne sont convertis en chaînes à l'aide des règles de conversion standard. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

lower("HELLO") = "bonjour".

lower(["HELLO"]) = "[\"bonjour\"]".

lpad(String, Int)

Renvoie l'argument String, complété à gauche par le nombre d'espaces spécifié par le deuxième argument. L'argument Int doit être compris entre 0 et 1000. Si la valeur fournie se situe en dehors de cette plage valide, l'argument est défini sur la valeur valide la plus proche (0 ou 1 000). Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

lpad("hello", 2) = "  hello".

lpad(1, 3) = "   1"

ltrim(String)

Supprime tous les espaces de début (tabulations et espaces) de la valeur String fournie. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

Ltrim(" h i ") = "bonjour".

machinelearning_predict (,, enregistrement) modelId roleArn

Utilisez cette machinelearning_predict fonction pour faire des prédictions en utilisant les données d'un MQTT message basé sur un modèle Amazon SageMaker AI. Pris en charge par SQL la version 2015-10-08 et versions ultérieures. Les arguments de la fonction machinelearning_predict sont :

La fonction renvoie un JSON objet avec les champs suivants :

mod(Decimal, Decimal)

Renvoie le reste résultant de la division du premier argument par le deuxième argument. Équivalent à remainder(Decimal, Decimal). Vous pouvez également utiliser « % » comme opérateur infixe pour la même fonctionnalité modulo. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : mod(8, 3) = 2.

nanol (,) AnyValue AnyValue

Renvoie le premier argument s'il s'agit d'une valeur Decimal valide. Sinon, le deuxième argument est renvoyé. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : Nanvl(8, 3) = 8.

newuuid()

Renvoie une valeur aléatoire de 16 octetsUUID. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple: newuuid() = 123a4567-b89c-12d3-e456-789012345000

numbytes(String)

Renvoie le nombre d'octets dans le codage UTF -8 de la chaîne fournie. Les règles de conversion standard s'appliquent aux arguments non-String. Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Exemples :

numbytes("hi") = 2

numbytes("€") = 3

parse_time(String, Long[, String])

Utilisez la fonction parse_time pour mettre en forme un horodatage dans un format date/heure lisible par l'utilisateur. Pris en charge par SQL la version 2016-03-23 et versions ultérieures. Pour convertir une chaîne d’horodatage en millisecondes, veuillez consulter time_to_epoch (Chaîne, Chaîne).

La fonction parse_time attend les arguments suivants :

Exemples :

Lorsque ce message est publié dans la rubrique « A/B », la charge utile {"ts": "1970.01.01 AD at 21:46:40 CST"} est envoyée au compartiment S3 :

{
    "ruleArn": "arn:aws:iot:us-east-2:ACCOUNT_ID:rule/RULE_NAME",
    "topicRulePayload": {
        "sql": "SELECT parse_time(\"yyyy.MM.dd G 'at' HH:mm:ss z\", 100000000, 'America/Belize' ) as ts FROM 'A/B'",

        "ruleDisabled": false,
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "s3": {
                    "roleArn": "arn:aws:iam::ACCOUNT_ID:rule:role/ROLE_NAME",
                    "bucketName": "BUCKET_NAME",
                    "key": "KEY_NAME"
                }
            }
        ],
        "ruleName": "RULE_NAME"
    }
} 

Lorsque ce message est publié dans la rubrique « A/B », une charge utile similaire à {"ts": "2017.06.09 AD at 17:19:46 UTC"} (mais avec la date et l'heure du moment) est envoyée au compartiment S3 :

{
    "ruleArn": "arn:aws:iot:us-east-2:ACCOUNT_ID:rule/RULE_NAME",
    "topicRulePayload": {
        "sql": "SELECT parse_time(\"yyyy.MM.dd G 'at' HH:mm:ss z\", timestamp() ) as ts FROM 'A/B'",
        "awsIotSqlVersion": "2016-03-23",
        "ruleDisabled": false,
        "actions": [
            {
                "s3": {
                    "roleArn": "arn:aws:iam::ACCOUNT_ID:rule:role/ROLE_NAME",
                    "bucketName": "BUCKET_NAME",
                    "key": "KEY_NAME"
                }
            }
        ],
        "ruleName": "RULE_NAME"
    }
} 

parse_time() peut également servir de modèle de substitution. Par exemple, lorsque ce message est publié dans la rubrique « A/B », la charge utile est envoyée au compartiment S3 avec la clé = « 2017 » :

{
    "ruleArn": "arn:aws:iot:us-east-2:ACCOUNT_ID:rule/RULE_NAME",
    "topicRulePayload": {
        "sql": "SELECT * FROM 'A/B'",
        "awsIotSqlVersion": "2016-03-23",
        "ruleDisabled": false,
        "actions": [{
            "s3": {
                "roleArn": "arn:aws:iam::ACCOUNT_ID:rule:role/ROLE_NAME",
                "bucketName": "BUCKET_NAME",
                "key": "${parse_time('yyyy', timestamp(), 'UTC')}"
            }
        }],
        "ruleName": "RULE_NAME"
    }
}

power(Decimal, Decimal)

Renvoie le premier argument augmenté vers le deuxième argument. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : power(2, 5) = 32.0.

principal()

Renvoie le principal utilisé par le terminal pour l’authentification, en fonction de la manière dont le message déclencheur a été publié. Le tableau suivant décrit le mandataire renvoyé pour chaque méthode et protocole de publication.

Les exemples suivants illustrent les différents types de valeurs qui peuvent être renvoyés par principal() :

rand()

Renvoie une valeur pseudo aléatoire, uniformément distribuée en double entre 0,0 et 1,0. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

rand() = 0.8231909191640703

regexp_matches(String, String)

Renvoie la valeur true si la chaîne (le premier argument) contient un élément correspondant à l'expression régulière (le deuxième argument). Si vous l’utilisez | dans l’expression régulière, utilisez-la avec ().

Exemples :

regexp_matches("aaaa", "a{2,}") = vrai.

regexp_matches("aaaa", "b") = false.

regexp_matches("aaa", "(aaa|bbb)") = vrai.

regexp_matches("bbb", "(aaa|bbb)") = vrai.

regexp_matches("ccc", "(aaa|bbb)") = false.

Deuxième argument :

Il doit s'agir d'une expression regex valide. Les types non-chaîne sont convertis en valeurs String à l'aide des règles de conversion standard. Selon le type, la chaîne résultante peut ne pas être une expression régulière valide. Si l'argument (converti) n'est pas un regex valide, le résultat est Undefined.

regexp_replace(String, String, String)

Remplace toutes les occurrences du deuxième argument (expression régulière) figurant dans le premier argument par le troisième argument. Fait référence aux groupes de capture avec « $ ». Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

regexp_replace("abcd", "bc", "x") = "axd".

regexp_replace("abcd", "b(.*)d", "$1") = "ac".

Deuxième argument :

Il doit s'agir d'une expression regex valide. Les types non-chaîne sont convertis en valeurs String à l'aide des règles de conversion standard. Selon le type, la chaîne résultante peut ne pas être une expression régulière valide. Si l'argument (converti) n'est pas une expression regex valide, le résultat est Undefined.

Troisième argument :

Il doit s'agir d'une chaîne de remplacement regex valide. (Peut faire référence à d'autres groupes de capture.) Les types non-chaîne sont convertis en valeurs String à l'aide des règles de conversion standard. Si l'argument (converti) n'est pas une chaîne de remplacement regex valide, le résultat est Undefined.

regexp_substr(String, String)

Recherche la première correspondance du deuxième paramètre (regex) dans le premier paramètre. Fait référence aux groupes de capture avec « $ ». Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

regexp_substr("hihihello", "hi") = "bonjour"

regexp_substr("hihihello", "(hi)*") = "hihi"

Deuxième argument :

Il doit s'agir d'une expression regex valide. Les types non-chaîne sont convertis en valeurs String à l'aide des règles de conversion standard. Selon le type, la chaîne résultante peut ne pas être une expression régulière valide. Si l'argument (converti) n'est pas une expression regex valide, le résultat est Undefined.

remainder(Decimal, Decimal)

Renvoie le reste résultant de la division du premier argument par le deuxième argument. Équivalent à mod(Decimal, Decimal). Vous pouvez également utiliser « % » comme opérateur infixe pour la même fonctionnalité modulo. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : remainder(8, 3) = 2.

replace(String, String, String)

Remplace toutes les occurrences du deuxième argument par le troisième argument dans le premier argument. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

replace("abcd", "bc", "x") = "axd".

replace("abcdabcd", "b", "x") = "axcdaxcd".

rpad(String, Int)

Renvoie l'argument chaîne, complété à droite par le nombre d'espaces spécifié dans le deuxième argument. L'argument Int doit être compris entre 0 et 1000. Si la valeur fournie se situe en dehors de cette plage valide, l'argument est défini sur la valeur valide la plus proche (0 ou 1 000). Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

rpad("hello", 2) = "hello  ".

rpad(1, 3) = "1   ".

round(Decimal)

Arrondit la valeur Decimal donnée à la valeur Int la plus proche. Si la valeur Decimal se situe à équidistance entre deux valeurs Int (par exemple, 0,5), la valeur Decimal est arrondie à la valeur supérieure. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : Round(1.2) = 1.

Round(1.5) = 2.

Round(1.7) = 2.

Round(-1.1) = -1.

Round(-1.5) = -2.

rtrim(String)

Supprime tous les espaces de fin (tabulations et espaces) de la valeur String fournie. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

rtrim(" h i ") = " sa lut "

sign(Decimal)

Renvoie le signe d'un chiffre donné. Lorsque le signe de l'argument est positif, la valeur 1 et renvoyée. Lorsque le signe de l'argument est négatif, la valeur -1 et renvoyée. Si l'argument est 0, la valeur 0 est renvoyée. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

sign(-7) = -1.

sign(0) = 0.

sign(13) = 1.

sin(Decimal)

Renvoie le sinus d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : sin(0) = 0,0

sinh(Decimal)

Renvoie le sinus hyperbolique d'un nombre. Les valeurs Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Le résultat est une valeur Decimal de double précision. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : sinh(2.3) = 4,936961805545957

sourceip()

Récupère l’adresse IP d’un appareil ou du routeur qui s’y connecte. Si votre appareil est connecté directement à Internet, la fonction renvoie l’adresse IP source de l’appareil. Si votre appareil est connecté à un routeur connecté à Internet, la fonction renvoie l’adresse IP source du routeur. Supporté par SQL la version 2016-03-23. sourceip()ne prend aucun paramètre.

Exemples :

sourceip()="192.158.1.38"

sourceip()="1.102.103.104"

sourceip()="2001:db8:ff00::12ab:34cd"

SQLexemple :

SELECT *, sourceip() as deviceIp FROM 'some/topic'

Exemples d'utilisation de la fonction sourceip () dans les actions de AWS IoT Core règles :

Exemple 1

L’exemple suivant montre comment appeler la fonction () en tant que modèle de substitution dans une action DynamoDB.

{
	"topicRulePayload": {
		"sql": "SELECT * AS message FROM 'some/topic'",
		"ruleDisabled": false,
		"awsIotSqlVersion": "2016-03-23",
		"actions": [
			{
				"dynamoDB": {
					"tableName": "my_ddb_table",
					"hashKeyField": "key",
					"hashKeyValue": "${sourceip()}",
					"rangeKeyField": "timestamp",
					"rangeKeyValue": "${timestamp()}",
					"roleArn": "arn:aws:iam::123456789012:role/aws_iot_dynamoDB"
				}
			}
		]
	}
}

Exemple 2

L'exemple suivant montre comment ajouter la fonction sourceip () en tant que propriété MQTT utilisateur à l'aide de modèles de substitution.

{
	"topicRulePayload": {
		"sql": "SELECT * FROM 'some/topic'",
		"ruleDisabled": false,
		"awsIotSqlVersion": "2016-03-23",
		"actions": [
			{
				"republish": {
					"topic": "${topic()}/republish",
					"roleArn": "arn:aws:iam::123456789012:role/aws_iot_republish",
					"headers": {
						"payloadFormatIndicator": "UTF8_DATA",
						"contentType": "rule/contentType",
						"correlationData": "cnVsZSBjb3JyZWxhdGlvbiBkYXRh",
						"userProperties": [
							{
								"key": "ruleKey1",
								"value": "ruleValue1"
							},
							{
								"key": "sourceip",
								"value": "${sourceip()}"
							}
						]
					}
				}
			}
		]
	}
}            

Vous pouvez récupérer l'adresse IP source à partir des messages transmis aux AWS IoT Core règles depuis les chemins Message Broker et Basic Ingest. Vous pouvez également récupérer l'adresse IP source pour IPv4 les deux IPv6 messages. L’adresse IP source sera affichée comme suit :

IPv6: yyyy:yyyy:yyyy::yyyy:yyyy

IPv4: xxx.xxx.xxx.xxx

substring(String, Int[, Int])

Prévoit un argument String suivi par une ou deux valeurs Int. Pour un argument String et un seul argument Int, cette fonction renvoie la sous-chaîne de l'argument String fourni provenant de l'index (de base 0, inclus) Int fourni à la fin de l'argument String. Pour un argument String et deux arguments Int, cette fonction renvoie la sous-chaîne de l'argument String fourni provenant du premier argument d'index Int (de base 0, inclus) dans le deuxième argument d'index Int (de base 0, inclus). Les index qui sont inférieurs à zéro sont définis sur zéro. Les index qui sont supérieurs à la longueur de String sont définis sur la longueur de String. Pour la version des trois arguments, si le premier index est supérieur (ou égale) au deuxième index, le résultat et vide String.

 Si les arguments fournis ne sont pas (String,Int) ou (String,Int,Int), les conversions standard sont appliquées aux arguments pour tenter de les convertir dans les types corrects. Si les types ne peuvent pas être convertis, le résultat de la fonction est Undefined. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

substring("012345", 0) = "012345".

substring("012345", 2) = "2345".

substring("012345", 2.745) = "2345".

substring(123, 2) = "3".

substring("012345", -1) = "012345".

substring(true, 1.2) = "true".

substring(false, -2.411E247) = "false".

substring("012345", 1, 3) = "12".

substring("012345", -50, 50) = "012345".

substring("012345", 3, 1) = "".

sql_version()

Renvoie la SQL version spécifiée dans cette règle. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

sql_version() = "2016-03-23"

sqrt(Decimal)

Renvoie la racine carrée d'un nombre en radians. Les arguments Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : sqrt(9) = 3.0.

startswith(String, String)

Renvoie une valeur Boolean si le premier argument de type chaîne commence par le deuxième argument de type chaîne. Si l'un des arguments est Null ou Undefined, le résultat a la valeur Undefined. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

startswith("ranger","ran") = true

tan(Decimal)

Renvoie la tangente d'un nombre en radians. Les valeurs Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : tan(3) = -0.1425465430742778

tanh(Decimal)

Renvoie la tangente hyperbolique d'un nombre en radians. Les valeurs Decimal sont arrondis pour une meilleure prévision avant l'application de la fonction. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple : tanh(2.3) = 0,9800963962661914

time_to_epoch (Chaîne, Chaîne)

Utilisez cette fonction time_to_epoch pour convertir une chaîne d’horodatage en un nombre de millisecondes en temps d’époque Unix. Pris en charge par SQL la version 2016-03-23 et versions ultérieures. Pour convertir des millisecondes en une chaîne d’horodatage formatée, veuillez consulter parse_time(String, Long[, String]).

La fonction time_to_epoch attend les arguments suivants :

Exemples :

time_to_epoch("2020-04-03 09:45:18 UTC+01:00", "yyyy-MM-dd HH:mm:ss VV")= 1585903518000

time_to_epoch("18 December 2015", "dd MMMM yyyy")= 1450396800000

time_to_epoch("2007-12-03 10:15:30.592 America/Los_Angeles", "yyyy-MM-dd HH:mm:ss.SSS z")= 1196705730592

timestamp()

Renvoie l'horodatage actuel en millisecondes à partir de 00:00:00 Temps universel coordonné (UTC), jeudi 1er janvier 1970, tel qu'observé par le moteur de règles. AWS IoT Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple: timestamp() = 1481825251155

topic(Decimal)

Il renvoie la rubrique vers laquelle le message qui a déclenché la règle a été envoyé. Si aucun paramètre n'est indiqué, la rubrique entière est renvoyée. Le paramètre Decimal est utilisé pour spécifier un segment de rubrique spécifique, avec le chiffre 1 désignant le premier segment. Pour la rubrique foo/bar/baz, topic(1) renvoie foo, topic(2) renvoie bar, et ainsi de suite. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

topic() = "things/myThings/thingOne"

topic(1) = "things"

Lorsque Basic Ingest est utilisé, le préfixe initial de la rubrique ($aws/rules/rule-name) n'est pas disponible pour la fonction topic(). Prenons l'exemple de la rubrique suivante :

$aws/rules/BuildingManager/Buildings/Building5/Floor2/Room201/Lights

topic() = "Buildings/Building5/Floor2/Room201/Lights"

topic(3) = "Floor2"

traceid()

Renvoie l'ID de trace (UUID) du MQTT message, ou Undefined si le message n'a pas été envoyéMQTT. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

traceid() = "12345678-1234-1234-1234-123456789012"

transformation (chaîne, objet, tableau)

Renvoie un tableau d’objets contenant le résultat de la transformation spécifiée du paramètre Object sur le paramètre Array.

Pris en charge par SQL la version 2016-03-23 et versions ultérieures.

Exemple 1 de fonction de transformation

Cet exemple montre comment la fonction transform() produit un tableau unique d’objets à partir d’un objet de données et d’un tableau.

Dans cet exemple, le message suivant est publié dans le MQTT sujetA/B.

{
    "attributes": {
        "data1": 1,
        "data2": 2
    },
    "values": [
        {
            "a": 3
        },
        {
            "b": 4
        },
        {
            "c": 5
        }
    ]
}

Cette SQL instruction pour une action de règle de sujet utilise la transform() fonction avec une String valeur deenrichArray. Dans cet exemple, Object est la propriété attributes de la charge utile du message et Array est le tableau values, qui contient trois objets.

select value transform("enrichArray", attributes, values) from 'A/B'

À la réception de la charge utile du message, l'SQLinstruction donne la réponse suivante.

[
  {
    "a": 3,
    "data1": 1,
    "data2": 2
  },
  {
    "b": 4,
    "data1": 1,
    "data2": 2
  },
  {
    "c": 5,
    "data1": 1,
    "data2": 2
  }
]

Exemple 2 de fonction de transformation

Cet exemple montre comment la fonction transform() peut utiliser des valeurs littérales pour inclure et renommer des attributs individuels à partir de la charge utile du message.

Dans cet exemple, le message suivant est publié dans le MQTT sujetA/B. Il s’agit du même message que celui utilisé dans Exemple 1 de fonction de transformation.

{
    "attributes": {
        "data1": 1,
        "data2": 2
    },
    "values": [
        {
            "a": 3
        },
        {
            "b": 4
        },
        {
            "c": 5
        }
    ]
}

Cette SQL instruction pour une action de règle de sujet utilise la transform() fonction avec une String valeur deenrichArray. Le Object dans la fonction transform() possède un seul attribut nommé key avec la valeur de attributes.data1 dans la charge utile du message et Array est le tableau values qui contient les trois mêmes objets que ceux utilisés dans l’exemple précédent.

select value transform("enrichArray", {"key": attributes.data1}, values) from 'A/B'

À la réception de la charge utile du message, cette SQL instruction donne la réponse suivante. Notez comment la propriété data1 est nommée key dans la réponse.

[
  {
    "a": 3,
    "key": 1
  },
  {
    "b": 4,
    "key": 1
  },
  {
    "c": 5,
    "key": 1
  }
]

Exemple 3 de fonction de transformation

Cet exemple montre comment la transform() fonction peut être utilisée dans des SELECT clauses imbriquées pour sélectionner plusieurs attributs et créer de nouveaux objets pour un traitement ultérieur.

Dans cet exemple, le message suivant est publié dans le MQTT sujetA/B.

{
  "data1": "example",
  "data2": {
    "a": "first attribute",
    "b": "second attribute",
    "c": [
      {
        "x": {
          "someInt": 5,
          "someString": "hello"
        },
        "y": true
      },
      {
        "x": {
          "someInt": 10,
          "someString": "world"
        },
        "y": false
      }
    ]
  }
}

La fonction Object for this transform est l'objet renvoyé par l'SELECTinstruction, qui contient les b éléments a et de l'data2objet du message. Le paramètre Array comprend les deux objets du tableau data2.c figurant dans le message d’origine.

select value transform('enrichArray', (select a, b from data2), (select value c from data2)) from 'A/B'

Avec le message précédent, l'SQLinstruction donne la réponse suivante.

[
  {
    "x": {
      "someInt": 5,
      "someString": "hello"
    },
    "y": true,
    "a": "first attribute",
    "b": "second attribute"
  },
  {
    "x": {
      "someInt": 10,
      "someString": "world"
    },
    "y": false,
    "a": "first attribute",
    "b": "second attribute"
  }
]

Le tableau renvoyé dans cette réponse peut être utilisé avec des actions de règles de rubrique qui prennent en charge batchMode.

trim(String)

Supprime tous les espaces de début et de fin de la valeur String fournie. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemple :

Trim(" hi ") = "bonjour"

trunc(Decimal, Int)

Tronque le premier argument du nombre de Decimal, spécifié par le deuxième argument. Si le deuxième argument est inférieur à zéro, il est défini sur zéro. Si le deuxième argument est supérieur à 34, il est défini sur 34. Les zéros de fin sont supprimés du résultat. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

trunc(2.3, 0) = 2.

trunc(2.3123, 2) = 2.31.

trunc(2.888, 2) = 2.88.

trunc(2.00, 5) = 2.

upper(String)

Renvoie la version en majuscules de la valeur String donnée. Les arguments non-String sont convertis en valeurs String à l'aide des règles de conversion standard. Pris en charge par SQL la version 2015-10-08 et versions ultérieures.

Exemples :

upper("hello") = "HELLO"

upper(["hello"]) = "[\"HELLO\"]"