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.

abs (Desimal)

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

Contoh: abs(-5) mengembalikan 5.

akuntid ()

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 cosinus terbalik dari angka dalam radian. Decimalargumen dibulatkan ke presisi ganda sebelum aplikasi fungsi. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: acos(0) = 1,5707963267948966

asin (Desimal)

Mengembalikan sinus terbalik dari angka 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 angka 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 didefinisikan dalam dua argumen.  Sudutnya 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: atan2(1, 0) = 1,5707963267948966

aws_lambda (FunctionARN, InputJson)

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

Anda harus memberikan AWS IoT lambda:InvokeFunction izin untuk menjalankan 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 muatan pesan JSON seperti:

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

aws_lambdaFungsi tersebut 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 muatan pesan MQTT lengkap, 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 'topik/subtopik'.

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

bit (Int, Int)

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

Contoh: bitand(13, 5) = 5

bitor (Int, Int)

Melakukan bitwise OR 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 (-convert). Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: bitor(13, 5) = 8

bitnot (Int)

Melakukan bitwise NOT 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. Pemeran berperilaku sebagian besar seperti konversi standar, dengan penambahan kemampuan untuk mentransmisikan angka ke atau dari Booleans. Jika AWS IoT tidak dapat menentukan cara melemparkan satu jenis ke jenis lainnya, hasilnya adalahUndefined. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru. Format: cast (nilai sebagai tipe).

Contoh:

cast(true as Int) = 1

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

Aturan casting:

ceil (Desimal)

Membulatkan yang diberikan Decimal 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 argumen yang diberikanInt. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

chr(65)= “A”.

chr(49)= “1".

klien ()

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"

concat ()

Menggabung array atau string. Fungsi ini menerima sejumlah argumen dan mengembalikan a String atau. Array 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")= “concat”

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 cosinus dari angka 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 suatu angka 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 diterjemahkan adalah dokumen JSON, objek yang dapat dialamatkan dikembalikan. Jika tidak, string yang diterjemahkan 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.

Decoding string yang dikodekan base64

Dalam contoh ini, payload pesan menyertakan nilai yang dikodekan.

{
    encoded_temp: "eyAidGVtcGVyYXR1cmUiOiAzMyB9Cg=="
}

decodeFungsi dalam pernyataan SQL ini menerjemahkan nilai dalam payload pesan.

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

Decoding encoded_temp nilai menghasilkan dokumen JSON valid berikut, yang memungkinkan pernyataan SELECT membaca nilai suhu.

{ "temperature": 33 }

Hasil dari pernyataan SELECT dalam contoh ini ditampilkan di sini.

{ "temp": 33 }

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

Decoding payload pesan protobuf

Anda dapat menggunakan fungsi decode SQL untuk mengkonfigurasi Aturan yang dapat memecahkan kode payload pesan protobuf Anda. Untuk informasi selengkapnya, lihat Menguraikan 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'

encode (nilai, EncodingScheme)

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

endswith (String, String)

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

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

exp (Desimal)

Mengembalikan e 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 Decimal ke 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 (TableName,,,,, roLearn partitionKeyName) partitionKeyValue sortKeyName sortKeyValue

Mengambil data dari tabel DynamoDB. get_dynamodb()memungkinkan Anda untuk query tabel DynamoDB sementara 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)

Referensi salah satu header MQTT5 berikut:contentType,,, payLoadFormatIndicator dan. responseTopic correlationData Fungsi ini mengambil salah satu string literal berikut sebagai argumen:content_type,, format_indicatorresponse_topic, dancorrelation_data. Untuk informasi selengkapnya, lihat tabel Argumen fungsi berikut.

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

Contoh berikut Aturan SQL mereferensikan salah satu header MQTT5 berikut:contentType,,, dan. payLoadFormatIndicator responseTopic 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_secret (secretID, secretType, kunci, roLearn)

Mengambil nilai terenkripsi SecretString atau SecretBinary bidang 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 (ThingName, ShadoName, 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 parameternya.

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 parameternya. shadowName

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

get_user_properties () userPropertyKey

Referensi Properti Pengguna, 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 referensi Properti Pengguna (jenis header properti MQTT5) ke 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 (0-based) dari argumen kedua sebagai substring dalam argumen pertama. Kedua argumen diharapkan sebagai string. Argumen yang bukan string dikenakan 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

isNull ()

Mengembalikan nilai true jika argumen adalah Null nilai. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

isNull(5) = salah.

isNull(Null) = benar.

isUndefined ()

Mengembalikan nilai true jika argumennyaUndefined. 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 String non-argumen. Didukung oleh SQL versi 2016-03-23 dan yang lebih baru.

Contoh:

length("hi")= 2

length(false)= 5

ln (Desimal)

Mengembalikan logaritma natural 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 basis 10 logaritma 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 Argumen non-string 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 (Tali, Int)

Mengembalikan String argumen, empuk di sisi kiri dengan jumlah spasi yang ditentukan oleh argumen kedua. IntArgumen harus antara 0 dan 1000. Jika nilai yang diberikan berada di luar rentang yang valid ini, argumen diatur 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 spasi putih terkemuka (tab dan spasi) dari yang disediakanString. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

machinelearning_predict (modelID, roLearn, rekam)

Gunakan machinelearning_predict fungsi untuk membuat prediksi menggunakan data dari pesan MQTT berdasarkan model Amazon. SageMaker Didukung oleh SQL versi 2015-10-08 dan yang lebih baru. Argumen untuk machinelearning_predict fungsi tersebut adalah:

Fungsi mengembalikan objek JSON dengan bidang-bidang berikut:

mod (Desimal, Desimal)

Mengembalikan sisa pembagian argumen pertama dengan argumen kedua. Setara dengansisanya (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 itu adalah validDecimal. Jika tidak, argumen kedua dikembalikan. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh: Nanvl(8, 3) = 8.

newuuid ()

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 pengkodean UTF-8 dari string yang disediakan. Aturan konversi standar berlaku untuk String non-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 tanggal/waktu yang dapat dibaca manusia. 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"
    }
} 

Saat pesan ini dipublikasikan ke topik 'A/B', muatan yang mirip dengan {"ts": "2017.06.09 AD at 17:19:46 UTC"} (tetapi dengan tanggal/waktu saat ini) 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', muatan 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 diangkat 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.

prinsipal ()

Mengembalikan prinsipal yang digunakan perangkat untuk otentikasi, berdasarkan bagaimana pesan pemicu dipublikasikan. 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, seragam didistribusikan 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 nilai 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 berupa ekspresi regex yang valid. Jenis non-string dikonversi untuk String menggunakan aturan konversi standar. Bergantung pada jenisnya, string yang dihasilkan mungkin bukan ekspresi reguler yang valid. Jika argumen (dikonversi) tidak valid regex, hasilnya adalah. Undefined

regexp_replace (String, String, String)

Menggantikan semua kemunculan argumen kedua (ekspresi reguler) dalam argumen pertama dengan argumen ketiga. Grup tangkapan referensi dengan “$”. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

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

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

Argumen kedua:

Harus berupa ekspresi regex yang valid. Jenis non-string dikonversi untuk String menggunakan aturan konversi standar. Bergantung 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.) Jenis non-string dikonversi untuk String menggunakan aturan konversi standar. Jika argumen (dikonversi) bukan string pengganti regex yang valid, hasilnya adalah. Undefined

regexp_substr (Tali, Tali)

Menemukan kecocokan pertama dari parameter kedua (regex) di parameter pertama. Grup tangkapan referensi 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 berupa ekspresi regex yang valid. Jenis non-string dikonversi untuk String menggunakan aturan konversi standar. Bergantung pada jenisnya, string yang dihasilkan mungkin bukan ekspresi reguler yang valid. Jika argumen (dikonversi) bukan ekspresi regex yang valid, hasilnya adalah. Undefined

sisanya (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)

Menggantikan 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, empuk di sisi kanan dengan jumlah spasi yang ditentukan dalam argumen kedua. IntArgumen harus antara 0 dan 1000. Jika nilai yang diberikan berada di luar rentang yang valid ini, argumen diatur 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 Decimal berjarak sama dari dua Int nilai (misalnya, 0,5), Decimal dibulatkan 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 (Tali)

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

Contoh:

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

tanda (Desimal)

Mengembalikan tanda nomor yang diberikan. Ketika tanda argumen positif, 1 dikembalikan. Ketika tanda argumen negatif, -1 dikembalikan. Jika argumen 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 angka 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 ke 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

sourceip ()

Mengambil alamat IP perangkat atau router yang terhubung dengannya. Jika perangkat Anda terhubung ke internet secara langsung, fungsi tersebut 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 AWS IoT Core tindakan aturan:

Contoh 1

Contoh berikut menunjukkan bagaimana 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 sourceip () fungsi 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 String diikuti oleh satu atau dua Int nilai. Untuk Int argumen String dan satu, fungsi ini mengembalikan substring yang disediakan String dari Int indeks yang disediakan (berbasis 0, inklusif) ke akhir. String Untuk Int argumen a String 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 ditetapkan 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 kosongString.

 Jika argumen yang diberikan bukan (String, Int), atau (String, Int, Int), konversi standar diterapkan ke 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)= “rue”.

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

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

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

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

sql_version ()

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 sebuah 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)

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

Contoh:

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

tan (Desimal)

Mengembalikan garis singgung angka dalam radian. Decimalnilai dibulatkan ke 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 angka dalam radian. Decimalnilai dibulatkan ke 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 timestamp menjadi beberapa milidetik dalam waktu epoch 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 Coordinated Universal Time (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 ke mana pesan yang memicu aturan dikirim. Jika tidak ada parameter yang ditentukan, seluruh topik dikembalikan. DecimalParameter ini digunakan untuk menentukan segmen topik tertentu, dengan 1 menunjuk segmen pertama. Untuk topikfoo/bar/baz, topik (1) kembalifoo, topik (2) kembalibar, dan sebagainya. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

topic()= “Hal-hal/Mitos/Hal-hal”

topic(1)= “hal-hal”

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

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

topic()= “Bangunan/Bangunan/Lantai/Kamar201/Lampu”

topic(3)= “Lantai2"

traceid ()

Mengembalikan ID jejak (UUID) 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-123456789012"

mengubah (String, Objek, Array)

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

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

Contoh fungsi transformasi 1

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

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

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

Pernyataan SQL ini untuk tindakan aturan topik menggunakan transform() fungsi dengan String nilai. enrichArray Dalam contoh ini, Object adalah attributes properti dari payload pesan dan Array 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
  }
]

Contoh fungsi transformasi 2

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

Dalam contoh ini, pesan berikut dipublikasikan ke topik MQTT. A/B Ini adalah pesan yang sama yang digunakan dalamContoh fungsi transformasi 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 nilai. enrichArray ObjectDalam transform() fungsi memiliki atribut tunggal bernama key dengan nilai attributes.data1 dalam payload pesan dan Array 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 tersebut dinamai key dalam tanggapan.

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

Contoh fungsi transformasi 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 MQTT. A/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
      }
    ]
  }
}

Fungsi Object untuk transformasi ini adalah objek yang dikembalikan oleh pernyataan SELECT, yang berisi a dan b elemen 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.

memangkas (Tali)

Menghapus semua spasi putih terdepan dan tertinggal dari yang disediakanString. Didukung oleh SQL versi 2015-10-08 dan yang lebih baru.

Contoh:

Trim(" hi ") = “hai”

batang (Desimal, Int)

Memangkas 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, itu diatur ke 34. Trailing zeroes 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 diberikan. String StringNon-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\ "]”