Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Fungsi

Anda dapat menggunakan fungsi bawaan berikut dalam klausa SELECT atau WHERE dari ekspresi SQL Anda.

Fungsi eksternal berikut ditagih setara dengan tindakan aturan: aws_lambda,, get_dynamodb() get_registry_data(), dan get_thing_shadow(). Anda juga ditagih untuk decode() fungsi hanya saat Anda men dekode pesan Protobuf ke JSON. Untuk detail selengkapnya, lihat halaman AWS IoT Core harga.

abs (Desimal)

Mengembalikan nilai absolut dari suatu angka. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: abs(-5) mengembalikan 5.

account time ()

Mengembalikan ID akun yang memiliki aturan ini sebagaiString. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

accountid() = “123456789012”

acos (Desimal)

Mengembalikan kosinus terbalik dari bilangan dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh Soal: acos(0) = 1.5707963267948966

asin (Desimal)

Mengembalikan sinus terbalik dari bilangan dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: asin(0) = 0.0

atan (Desimal)

Mengembalikan tangen terbalik dari bilangan dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: atan(0) = 0.0

atan2 (Desimal, Desimal)

Mengembalikan sudut, dalam radian, antara sumbu x positif dan titik (x, y) yang ditentukan dalam dua argumen.  Sudut positif untuk sudut berlawanan arah jarum jam (setengah bidang atas, y > 0), dan negatif untuk sudut searah jarum jam (setengah bidang bawah, y < 0). Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh Soal: atan2(1, 0) = 1.5707963267948966

aws_lambda (fungsiArn, masukanJSON)

Memanggil fungsi Lambda yang ditentukan yang inputJson diteruskan ke fungsi Lambda dan mengembalikan JSON yang dihasilkan oleh fungsi Lambda.

Anda harus memberikan AWS IoT lambda:InvokeFunction izin untuk memanggil fungsi Lambda yang ditentukan. Contoh berikut menunjukkan cara memberikan lambda:InvokeFunction izin menggunakan 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"

Berikut ini adalah argumen untuk add-permission perintah:

Diberikan payload pesan JSON seperti:

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

aws_lambdaFungsi ini dapat digunakan untuk memanggil fungsi Lambda sebagai berikut.

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

Jika Anda ingin meneruskan payload pesan MQTT penuh, Anda dapat menentukan payload JSON menggunakan '*', seperti contoh berikut.

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

payload.inner.elementmemilih data dari pesan yang dipublikasikan pada topik 'topic/subtopic'.

some.valuememilih data dari output yang dihasilkan oleh fungsi Lambda.

bit (Int, Int)

Melakukan bitwise AND pada representasi bit dari dua argumen Int (-konversi). Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: bitand(13, 5) = 5

bit (Int, Int)

Melakukan OR bitwise dari representasi bit dari dua argumen. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: bitor(8, 5) = 13

bitxor (Int, Int)

Melakukan XOR bitwise pada representasi bit dari dua argumen Int (-konversi). Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: bitor(13, 5) = 8

bitnot (Int)

Melakukan NOT bitwise pada representasi bit dari argumen Int (-convert). Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: bitnot(13) = 2

pemeran ()

Mengkonversi nilai dari satu tipe data ke yang lain. Cast berperilaku sebagian besar seperti konversi standar, dengan penambahan kemampuan untuk mentransmisikan angka ke atau dari Boolean. Jika AWS IoT tidak dapat menentukan cara mentransmisikan satu jenis ke jenis lainnya, hasilnya adalahUndefined. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru. Format: pemeran (valuesebagaitype).

Contoh:

cast(true as Int) = 1

Kata kunci berikut mungkin muncul setelah “as” saat memanggilcast:

Aturan casting:

ceil (Desimal)

Membul Decimal atkan yang diberikan ke yang terdekatInt. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

ceil(1.2)= 2

ceil(-1.2)= -1

chr (Tali)

Mengembalikan karakter ASCII yang sesuai dengan Int argumen yang diberikan. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

chr(65)= “A”.

chr(49)= “1".

client ()

Mengembalikan ID klien MQTT yang mengirim pesan, atau n/a jika pesan tidak dikirim melalui MQTT. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

clientid() = “123456789012”

konkat ()

Menggabungkan array atau string. Fungsi ini menerima sejumlah argumen dan mengembalikan a String atau anArray. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

concat() = Undefined.

concat(1) = “1".

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

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

concat("con", "cat")= “konkat”

concat(1, "hello")= “1halo”

concat("he","is","man")= “Heisman”

concat([1, 2, 3], "hello", [4, 5, 6])= [1, 2, 3, “halo”, 4, 5, 6]

cos (Desimal)

Mengembalikan kosinus dari bilangan dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

cos(0)= 1.

cosh (Desimal)

Mengembalikan kosinus hiperbolik dari bilangan dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: cosh(2.3) = 5.037220649268761.

decode (nilai, decodingScheme)

Gunakan decode fungsi untuk memecahkan kode nilai yang dikodekan. Jika string yang didekodekan adalah dokumen JSON, objek yang dapat dialamatkan dikembalikan. Jika tidak, string yang didekodekan dikembalikan sebagai string. Fungsi mengembalikan NULL jika string tidak dapat diterjemahkan. Fungsi ini mendukung decoding string yang dikodekan base64 dan format pesan Protocol Buffer (protobuf).

Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Menguraikan kode string yang dikodekan base64

Dalam contoh ini, payload pesan menyertakan nilai yang dikodekan.

{
    encoded_temp: "eyAidGVtcGVyYXR1cmUiOiAzMyB9Cg=="
}

decodeFungsi dalam pernyataan SQL ini memecahkan kode nilai dalam payload pesan.

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

Mengur encoded_temp aikan nilai menghasilkan dokumen JSON yang valid berikut, yang memungkinkan pernyataan SELECT untuk membaca nilai suhu.

{ "temperature": 33 }

Hasil pernyataan SELECT dalam contoh ini ditampilkan di sini.

{ "temp": 33 }

Jika nilai yang didekodekan bukan dokumen JSON yang valid, nilai yang didekodekan akan dikembalikan sebagai string.

Menguraikan muatan pesan protobuf

Anda dapat menggunakan fungsi decode SQL untuk mengonfigurasi Aturan yang dapat memecahkan kode payload pesan protobuf Anda. Untuk informasi selengkapnya, lihat Mengur aikan muatan pesan protobuf.

Tanda tangan fungsi terlihat seperti berikut:

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

Contoh ekspresi SQL menggunakan fungsi decode SQL dapat terlihat seperti berikut:

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

menyandikan (nilai, EncodingScheme)

Gunakan encode fungsi untuk menyandikan payload, yang berpotensi berupa data non-JSON, ke dalam representasi string berdasarkan skema pengkodean. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

endswith (String, String)

Mengem Boolean balikan sebuah menunjukkan apakah String argumen pertama berakhir dengan String argumen kedua. Jika salah satu argum Null en adalah atauUndefined, hasilnya adalahUndefined. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: endswith("cat","at") = benar.

exp (Desimal)

Mengembalikan e yang diangkat ke Decimal argumen. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: exp(1) = e.

lantai (Desimal)

Membulatkan yang diberikan ke Decimal bawah ke yang terdekatInt. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

floor(1.2)= 1

floor(-1.2)= -2

memperoleh

Mengekstrak nilai dari tipe seperti koleksi (Array, String, Object). Tidak ada konversi yang diterapkan pada argumen pertama. Konversi berlaku seperti yang didokumentasikan dalam tabel ke argumen kedua. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

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

get("abc", 0)= “a”

get_dynamodb (Nama tabel, partisi, partisi, mengurutkan, mengurutkanKeyName, roLearnKeyValue) KeyName KeyValue

Mengambil data dari tabel DynamoDB. get_dynamodb()memungkinkan Anda untuk menanyakan tabel DynamoDB saat aturan dievaluasi. Anda dapat memfilter atau menambah muatan pesan menggunakan data yang diambil dari DynamoDB. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

get_dynamodb()mengambil parameter berikut:

Sebagai contoh cara menggunakanget_dynamodb(), katakanlah Anda memiliki tabel DynamoDB yang berisi ID perangkat dan informasi lokasi untuk semua perangkat yang terhubung. AWS IoT Pernyataan SELECT berikut menggunakan get_dynamodb() fungsi untuk mengambil lokasi untuk ID perangkat yang ditentukan:

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

get_mqtt_property (nama)

Mereferensikan salah satu header MQTT5 berikut:contentType,,payLoadFormatIndicator, responseTopic dan. correlationData Fungsi ini mengambil salah satu string literal berikut sebagai argumen:content_type,format_indicator,response_topic, dancorrelation_data. Untuk informasi selengkapnya, lihat tabel argum en Fungsi berikut.

Tabel berikut menunjukkan argumen fungsi yang dapat diterima dan tipe pengembalian terkait untuk get_mqtt_property fungsi:

Contoh berikut Aturan SQL mereferensikan salah satu header MQTT5 berikut:contentType,,payLoadFormatIndicator, responseTopic dan. correlationData

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_or_default (ekspresi, Nilai default)

Mengembalikan nilai default di parameter kedua jika ditentukan atau mengembalikan undefined, ketika ekspresi dalam parameter pertama mengembalikan null, undefined, atau gagal. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

get_or_default()mengambil parameter berikut:

Tabel berikut menunjukkan argumen fungsi yang dapat diterima untuk setiap argumen dan output terkaitnya:

Contoh:

Contoh 1:

Contoh berikut memberikan nilai defaultValue jika tabel DynamoDB atau kueri gagal:

SELECT 
    device_id,
    get_or_default(
        get_dynamodb("DeviceConfig", "deviceId", nonExistentId, "arn:aws:iam::123456789012:role/ROLE_NAME"),
        {"mode": "standard", "timeout": 30, "enabled": true }
    ) as config
FROM 'device/telemetry'

Contoh 2:

Contoh berikut memberikan nilai default aman “TIDAK DIKETAHUI” jika status tidak ditentukan:

SELECT 
  get_or_default( CASE status
    WHEN 'active' THEN 'GOOD'
    WHEN 'inactive' THEN 'BAD'/
    ELSE 'UNKNOWN'
  END, 'UNKNOWN') as status_category
FROM 'topic/subtopic'

Contoh 3:

Contoh berikut menunjukkan bagaimana Anda juga dapat menggunakan get_or_default dengan satu parameter. Ini berguna dalam skenario di mana Anda mungkin tidak memiliki nilai default yang jelas, tetapi Anda tidak ingin eksekusi aturan gagal.

SELECT 
  get_dynamodb("DeviceConfig", "deviceId", nonExistentId, "arn:aws:iam::123456789012:role/ROLE_NAME") as config
FROM 'device/telemetry'

Jika pencarian DynamoDB gagal, eksekusi aturan akan gagal, dan tidak ada tindakan yang akan dieksekusi. Jika SQL berikut digunakan sebagai gantinya:

SELECT 
  get_or_default(get_dynamodb("DeviceConfig", "deviceId", nonExistentId, "arn:aws:iam::123456789012:role/ROLE_NAME")) as config
FROM 'device/telemetry'

Pernyataan get_or_default akan mengevaluasi keUndefined, jadi dalam contoh ini pernyataan SELECT secara keseluruhan akan mengevaluasi ke {} dan tindakan aturan apa pun akan dicoba.

get_registry_data (registryAPI, ThingName, ROLearn)

Mengambil AWS IoT data registri sesuatu dalam AWS IoT aturan. Anda dapat membaca data registri (seperti atribut, tipe benda, dan grup benda milik perangkat) dan menggunakan informasi ini untuk menyaring, memperkaya, atau merutekan pesan secara dinamis. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

get_registry_data()mengambil parameter berikut:

Format respons get_registry_data fungsi sama dengan API registri yang dipanggil. Untuk informasi selengkapnya, lihat DescribeThing dan ListThingGroupsForThing API.

Contoh:

Anda dapat mengambil informasi jenis benda untuk memungkinkan pemfilteran pesan AWS IoT Core peristiwa siklus hidup untuk hal-hal (dengan nama benda yang cocok dengan id klien MQTT) di mana tipe benda beradatestenv.

SELECT * 
FROM '$aws/events/lifecycle/+' 
WHERE 
    get_registry_data("DescribeThing",clientId,[roleArn]).thingTypeName='testenv'

Contoh:

Anda dapat mengambil atribut benda untuk perangkat dengan nama benda sensor1 untuk semua pesan yang dikirim oleh perangkat gateway-nyagateway1.

SELECT *, get_registry_data("DescribeThing","sensor1",[roleArn]).attributes.temperature_threhold AS device1_tempthreshold 
FROM home1/gateway1/sensor1/#

get_secret (SecretID, SecretType, kunci, roLearn)

Mengambil nilai terenkripsi SecretString atau SecretBinary bidang dari versi rahasia saat ini di AWS Secrets Manager. Untuk informasi lebih lanjut tentang membuat dan memelihara rahasia, lihat CreateSecret, UpdateSecret, dan PutSecretValue.

get_secret()mengambil parameter berikut:

Contoh:

Anda dapat menggunakan get_secret fungsi dalam header otentikasi dalam tindakan aturan HTTPS, seperti pada contoh otentikasi kunci API berikut.

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

Untuk informasi selengkapnya tentang tindakan aturan HTTPS, lihatHTTP.

get_thing_shadow (Nama benda, ShadowName, ROLearn)

Mengembalikan bayangan yang ditentukan dari hal yang ditentukan. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

Saat digunakan dengan bayangan bernama, berikan shadowName parameter.

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

Saat digunakan dengan bayangan yang tidak disebutkan namanya, hilangkan parameter. shadowName

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

get_user_properties (pengguna) PropertyKey

Referensi User Properties, yang merupakan salah satu jenis header properti yang didukung di MQTT5.

Argumen fungsi

Untuk Properti Pengguna berikut di header pesan:

Tabel berikut menunjukkan perilaku SQL yang diharapkan:

Contoh berikut Aturan SQL mereferensikan User Properties (jenis header properti MQTT5) ke dalam payload:

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

Fungsi hashing

AWS IoT menyediakan fungsi hashing berikut:

Semua fungsi hash mengharapkan satu argumen string. Hasilnya adalah nilai hash dari string itu. Konversi string standar berlaku untuk argumen non-string. Semua fungsi hash didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

md2("hello")= “a9046c73e00331af68917d3804f70655"

md5("hello")= “5d41402abc4b2a76b9719d911017c592”

indexof (String, String)

Mengembalikan indeks pertama (berbasis 0) dari argumen kedua sebagai substring dalam argumen pertama. Kedua argumen diharapkan sebagai string. Argumen yang bukan string tunduk pada aturan konversi string standar. Fungsi ini tidak berlaku untuk array, hanya untuk string. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

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

Adalah Nol ()

Mengembalikan nilai true jika argumennya adalah Null nilai. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

isNull(5) = salah.

isNull(Null) = benar.

IsUndefined ()

Mengembalikan true jika argumennya adalahUndefined. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

isUndefined(5) = salah.

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

panjang (String)

Mengembalikan jumlah karakter dalam string yang disediakan. Aturan konversi standar berlaku untuk non- String argumen. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

length("hi")= 2

length(false)= 5

ln (Desimal)

Mengembalikan logaritma alami dari argumen. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: ln(e) = 1.

log (Desimal)

Mengembalikan logaritma dasar 10 dari argumen. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: log(100) = 2.0.

lebih rendah (String)

Mengembalikan versi huruf kecil dari yang diberikan. String Non-stringargumen dikonversi ke string menggunakan aturan konversi standar. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

lower("HELLO")= “halo”.

lower(["HELLO"])= “[\" halo\ "]”.

lpad (String, Int)

Mengem String balikan argumen, dilapisi di sisi kiri dengan jumlah spasi yang ditentukan oleh argumen kedua. Ar Int gumen harus antara 0 dan 1000. Jika nilai yang diberikan berada di luar rentang valid ini, argumen disetel ke nilai valid terdekat (0 atau 1000). Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

lpad(1, 3) = "   1"

ltrim (Tali)

Menghapus semua ruang putih utama (tab dan spasi) dari yang disediakanString. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

Ltrim(" h i ")= “hai”.

mod (Desimal, Desimal)

Mengembalikan sisa pembagian argumen pertama dengan argumen kedua. Setara dengansisa (Desimal, Desimal). Anda juga dapat menggunakan “%” sebagai operator infix untuk fungsionalitas modulo yang sama. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: mod(8, 3) = 2.

nanvl (AnyValue, AnyValue)

Mengembalikan argumen pertama jika validDecimal. Jika tidak, argumen kedua dikembalikan. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: Nanvl(8, 3) = 8.

new new ()

Mengembalikan UUID 16-byte acak. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

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

numbytes (String)

Mengembalikan jumlah byte dalam peng UTF-8 kodean string yang disediakan. Aturan konversi standar berlaku untuk non- String argumen. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

numbytes("hi")= 2

numbytes("€") = 3

parse_time (String, Panjang [, String])

Gunakan parse_time fungsi untuk memformat stempel waktu menjadi format yang dapat dibaca manusia date/time . Didukung oleh SQL versi 2016-03-23 dan yang lebih baru. Untuk mengubah string stempel waktu menjadi milidetik, lihat. time_to_epoch (String, String)

parse_timeFungsi mengharapkan argumen berikut:

Contoh:

Ketika pesan ini dipublikasikan ke topik A/B '', payload {"ts": "1970.01.01 AD at 21:46:40 CST"} dikirim ke bucket 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"
    }
} 

Ketika pesan ini dipublikasikan ke topik 'A/B', payload yang mirip dengan {"ts": "2017.06.09 AD at 17:19:46 UTC"} (tetapi dengan saat ini date/time) dikirim ke bucket 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()juga dapat digunakan sebagai template substitusi. Misalnya, ketika pesan ini dipublikasikan ke topik 'A/B', payload dikirim ke bucket S3 dengan kunci = “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"
    }
}

kekuatan (Desimal, Desimal)

Mengembalikan argumen pertama yang diajukan ke argumen kedua. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: power(2, 5) = 32.0.

kepala sekolah ()

Mengembalikan prinsip yang digunakan perangkat untuk otentikasi, berdasarkan bagaimana pesan pemicu diterbitkan. Tabel berikut menjelaskan prinsip yang dikembalikan untuk setiap metode penerbitan dan protokol.

Contoh berikut menunjukkan berbagai jenis nilai yang principal() dapat dikembalikan:

rand ()

Mengembalikan pseudorandom, didistribusikan secara seragam ganda antara 0,0 dan 1,0. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

rand()= 0.8231909191640703

regexp_matches (String, String)

Mengembalikan true jika string (argumen pertama) berisi kecocokan untuk ekspresi reguler (argumen kedua). Jika Anda menggunakan | dalam ekspresi reguler, gunakan dengan().

Contoh:

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

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

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

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

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

Argumen kedua:

Harus ekspresi regex yang valid. Non-string jenis dikonversi String menggunakan aturan konversi standar. Tergantung pada jenisnya, string yang dihasilkan mungkin bukan ekspresi reguler yang valid. Jika argumen (dikonversi) bukan regex yang valid, hasilnya adalah. Undefined

regexp_replace (String, String, String)

Mengganti semua kemunculan argumen kedua (ekspresi reguler) di argumen pertama dengan argumen ketiga. Referensi grup tangkapan dengan “$”. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

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

Argumen kedua:

Harus ekspresi regex yang valid. Non-string jenis dikonversi String menggunakan aturan konversi standar. Tergantung pada jenisnya, string yang dihasilkan mungkin bukan ekspresi reguler yang valid. Jika argumen (dikonversi) bukan ekspresi regex yang valid, hasilnya adalah. Undefined

Argumen ketiga:

Harus berupa string pengganti regex yang valid. (Dapat mereferensikan grup tangkapan.) Non-string jenis dikonversi String menggunakan aturan konversi standar. Jika argumen (dikonversi) bukan string pengganti regex yang valid, hasilnya adalah. Undefined

regexp_substr (String, String)

Menemukan kecocokan pertama dari parameter kedua (regex) di parameter pertama. Referensi grup tangkapan dengan “$”. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

regexp_substr("hihihello", "hi")= “hai”

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

Argumen kedua:

Harus ekspresi regex yang valid. Non-string jenis dikonversi untuk String menggunakan aturan konversi standar. Tergantung pada jenisnya, string yang dihasilkan mungkin bukan ekspresi reguler yang valid. Jika argumen (dikonversi) bukan ekspresi regex yang valid, hasilnya adalah. Undefined

sisa (Desimal, Desimal)

Mengembalikan sisa pembagian argumen pertama dengan argumen kedua. Setara denganmod (Desimal, Desimal). Anda juga dapat menggunakan “%” sebagai operator infix untuk fungsionalitas modulo yang sama. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: remainder(8, 3) = 2.

ganti (String, String, String)

Mengganti semua kemunculan argumen kedua dalam argumen pertama dengan argumen ketiga. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

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

rpad (String, Int)

Mengembalikan argumen string, dilapisi di sisi kanan dengan jumlah spasi yang ditentukan dalam argumen kedua. Ar Int gumen harus antara 0 dan 1000. Jika nilai yang diberikan berada di luar rentang valid ini, argumen disetel ke nilai valid terdekat (0 atau 1000). Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

rpad(1, 3) = "1   ".

bulat (Desimal)

Membulatkan yang diberikan Decimal ke yang terdekatInt. Jika jar Decimal aknya sama dari dua Int nilai (misalnya, 0,5), dibulatkan Decimal ke atas. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: Round(1.2) = 1.

Round(1.5)= 2.

Round(1.7)= 2.

Round(-1.1)= -1.

Round(-1.5)= -2.

rtrim (String)

Menghapus semua spasi putih (tab dan spasi) dari yang disediakanString. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

rtrim(" h i ")= "h i”

tanda (Desimal)

Mengembalikan tanda angka yang diberikan. Ketika tanda argumen positif, 1 dikembalikan. Ketika tanda argumen negatif, -1 dikembalikan. Jika argumennya adalah 0, 0 dikembalikan. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

sign(-7)= -1.

sign(0)= 0.

sign(13)= 1.

sin (Desimal)

Mengembalikan sinus dari bilangan dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: sin(0) = 0.0

sinh (Desimal)

Mengembalikan sinus hiperbolik dari suatu angka. Decimalnilai dibulatkan menjadi presisi ganda sebelum aplikasi fungsi. Hasilnya adalah Decimal nilai presisi ganda. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: sinh(2.3) = 4.936961805545957

sumber ()

Mengambil alamat IP perangkat atau router yang terhubung dengannya. Jika perangkat Anda terhubung ke internet secara langsung, fungsi akan mengembalikan alamat IP sumber perangkat. Jika perangkat Anda terhubung ke router yang terhubung ke internet, fungsi tersebut akan mengembalikan alamat IP sumber router. Didukung oleh SQL versi 2016-03-23. sourceip()tidak mengambil parameter apa pun.

Contoh:

sourceip()="192.158.1.38"

sourceip()="1.102.103.104"

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

Contoh SQL:

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

Contoh cara menggunakan fungsi sourceip () dalam tindakan AWS IoT Core aturan:

Contoh 1

Contoh berikut menunjukkan cara memanggil fungsi () sebagai template substitusi dalam tindakan 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"
				}
			}
		]
	}
}

Contoh 2

Contoh berikut menunjukkan cara menambahkan fungsi sourceip () sebagai properti pengguna MQTT menggunakan template substitusi.

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

Anda dapat mengambil alamat IP sumber dari pesan yang diteruskan ke AWS IoT Core aturan dari jalur Message Broker dan Basic Ingest. Anda juga dapat mengambil IP sumber untuk pesan IPv4 dan IPv6. IP sumber akan ditampilkan seperti berikut:

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

IPv4: xxx.xxx.xxx.xxx

substring (String, Int [, Int])

Mengharapkan a String diikuti oleh satu atau dua Int nilai. Untuk Int argumen String a dan satu, fungsi ini mengembalikan substring yang disediakan String dari Int indeks yang disediakan (berbasis 0, inklusif) ke akhir. String Untuk Int argumen String a dan dua, fungsi ini mengembalikan substring yang disediakan String dari argumen Int indeks pertama (berbasis 0, inklusif) ke argumen Int indeks kedua (berbasis 0, eksklusif). Indeks yang kurang dari nol diatur ke nol. Indeks yang lebih besar dari String panjang diatur ke String panjang. Untuk versi tiga argumen, jika indeks pertama lebih besar dari (atau sama dengan) indeks kedua, hasilnya adalah kosongString.

 Jika argumen yang diberikan bukan (String,Int), atau (StringInt,,Int), konversi standar diterapkan pada argumen untuk mencoba mengubahnya menjadi tipe yang benar. Jika tipe tidak dapat dikonversi, hasil fungsinya adalahUndefined. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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)= “jalan”.

substring(false, -2.411E247)= “salah”.

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

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

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

sql_versi ()

Mengembalikan versi SQL yang ditentukan dalam aturan ini. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

sql_version()= “2016-03-23”

sqrt (Desimal)

Mengembalikan akar kuadrat dari angka. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: sqrt(9) = 3.0.

startswith (String, String)

Meng Boolean embalikan, apakah argumen string pertama dimulai dengan argumen string kedua. Jika salah satu argum Null en adalah atauUndefined, hasilnya adalahUndefined. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

tan (Desimal)

Mengembalikan garis singgung dari bilangan dalam radian. Decimalnilai dibulatkan menjadi presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: tan(3) = -0.1425465430742778

tanh (Desimal)

Mengembalikan tangen hiperbolik dari bilangan dalam radian. Decimalnilai dibulatkan menjadi presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: tanh(2.3) = 0.9800963962661914

time_to_epoch (String, String)

Gunakan time_to_epoch fungsi untuk mengubah string stempel waktu menjadi sejumlah milidetik dalam waktu zaman Unix. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru. Untuk mengonversi milidetik ke string stempel waktu yang diformat, lihat. parse_time (String, Panjang [, String])

time_to_epochFungsi mengharapkan argumen berikut:

Contoh:

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

stempel waktu ()

Mengembalikan stempel waktu saat ini dalam milidetik dari 00:00:00 Waktu Universal Terkoordinasi (UTC), Kamis, 1 Januari 1970, seperti yang diamati oleh mesin aturan. AWS IoT Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: timestamp() = 1481825251155

topik (Desimal)

Mengembalikan topik yang mengirim pesan yang memicu aturan. Jika tidak ada parameter yang ditentukan, seluruh topik dikembalikan. DecimalParameter digunakan untuk menentukan segmen topik tertentu, dengan 1 menunjuk segmen pertama. Untuk topikfoo/bar/baz, topik (1) kembalifoo, topik (2) kembalibar, dan seterusnya. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

topic()= "things/myThings/ThingOne”

topic(1)= “hal-hal”

Ketika Basic Ingest digunakan, awalan awal topik ($aws/rules/rule-name) tidak tersedia untuk fungsi topic (). Misalnya, mengingat topik:

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

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

topic(3)= “Lantai2"

Traceid ()

Mengembalikan ID jejak (UUID) dari pesan MQTT, atau Undefined jika pesan tidak dikirim melalui MQTT. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

transformasi (String, Objek, Array)

Mengembalikan array objek yang berisi hasil transformasi Object parameter yang ditentukan pada Array parameter.

Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Transformasi fungsi contoh 1

Contoh ini menunjukkan bagaimana transform() fungsi menghasilkan satu array objek dari objek data dan array.

Dalam contoh ini, pesan berikut dipublikasikan ke topik A/B MQTT.

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

Pernyataan SQL ini untuk tindakan aturan topik menggunakan transform() fungsi dengan String nilaienrichArray. Dalam contoh ini, Object adalah attributes properti dari payload pesan dan Array merupakan values array, yang berisi tiga objek.

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

Setelah menerima payload pesan, pernyataan SQL mengevaluasi respons berikut.

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

Transformasi fungsi contoh 2

Contoh ini menunjukkan bagaimana transform() fungsi dapat menggunakan nilai literal untuk memasukkan dan mengganti nama atribut individual dari payload pesan.

Dalam contoh ini, pesan berikut dipublikasikan ke topik A/B MQTT. Ini adalah pesan yang sama yang digunakan diTransformasi fungsi contoh 1.

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

Pernyataan SQL ini untuk tindakan aturan topik menggunakan transform() fungsi dengan String nilaienrichArray. transform()Fungsi Object in memiliki atribut tunggal bernama key dengan nilai attributes.data1 dalam payload pesan dan Array merupakan values array, yang berisi tiga objek yang sama yang digunakan dalam contoh sebelumnya.

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

Setelah menerima payload pesan, pernyataan SQL ini mengevaluasi respons berikut. Perhatikan bagaimana data1 properti diberi nama key dalam tanggapan.

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

Transformasi fungsi contoh 3

Contoh ini menunjukkan bagaimana transform() fungsi dapat digunakan dalam klausa SELECT bersarang untuk memilih beberapa atribut dan membuat objek baru untuk pemrosesan selanjutnya.

Dalam contoh ini, pesan berikut dipublikasikan ke topik A/B MQTT.

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

Fungsi transformasi Object untuk ini adalah objek yang dikembalikan oleh pernyataan SELECT, yang berisi b elemen a dan dari data2 objek pesan. ArrayParameter terdiri dari dua objek dari data2.c array dalam pesan asli.

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

Dengan pesan sebelumnya, pernyataan SQL mengevaluasi respons berikut.

[
  {
    "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"
  }
]

Array yang dikembalikan dalam respons ini dapat digunakan dengan tindakan aturan topik yang mendukungbatchMode.

trim (String)

Menghapus semua spasi putih di depan dan di belakang dari yang disediakanString. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

Trim(" hi ") = “hai”

trunc (Desimal, Int)

Memotong argumen pertama ke jumlah Decimal tempat yang ditentukan oleh argumen kedua. Jika argumen kedua kurang dari nol, itu diatur ke nol. Jika argumen kedua lebih besar dari 34, maka ditetapkan ke 34. Nol terbelakang dilucuti dari hasilnya. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

trunc(2.3, 0)= 2.

trunc(2.3123, 2)= 2,31.

trunc(2.888, 2)= 2,88.

trunc(2.00, 5)= 2.

atas (String)

Mengembalikan versi huruf besar dari yang diberikanString. Non- String argumen dikonversi untuk String menggunakan aturan konversi standar. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

upper("hello")= “HALO”

upper(["hello"])= “[\" HALO\ "]”