組み込みSQL関数
ルールエンジンはさまざまな組み込み関数を提供しています。これらの関数はSQL内で利用でき、以下のような基本的なデータ処理を実現できます。
- 数学関数
- データ型判定関数
- データ型変換関数
- 文字列操作関数
- マップ操作関数
- 配列操作関数
- ハッシュ関数
- 圧縮・解凍関数
- ビット演算関数
- ビット列操作関数
- エンコード・デコード関数
- 日時変換関数
- UUID関数
- システム関数
- 条件関数
本節のすべての関数宣言は以下の形式に準拠しています。
FuncName(Arg 1: Type 1 | ..., ...) -> Type 1 | ...例えば、abs(X: integer | float) -> integer | float は、引数 X のデータ型が整数または浮動小数点数のいずれかであり、戻り値のデータ型もそれに対応して整数または浮動小数点数であることを意味します。
指定された引数が定められた範囲を超えるか、サポートされていないデータ型を使用した場合、現在のSQL実行は失敗し、失敗回数が1増加します。
TIP
- 一部のエスケープシーケンスは使用時にアンエスケープが必要です。詳細はunescape関数を参照してください。
- EMQX 5.0以降では、複雑なデータ変換にjq構文もサポートしています。詳細はjq関数セクションを参照してください。
数学関数
EMQXは幅広い数学関数をサポートしています。
- 三角関数および双曲線関数：sin, cos, tan, asin, acos, atan, sinh, cosh, tanh, asinh, acosh, atanh。
- 数値関数：abs, ceil, floor, round, sqrt, fmod。
- 指数関数および対数関数：exp, power, log, log10, log2。
abs(X: integer | float) -> integer | float
数値 X の絶対値を返します。例：
abs(-12) = 12
abs(-1.2) = 1.2acos(X: integer | float) -> float
X のアークコサイン（ラジアン単位）を返します。X の範囲は [-1, 1] です。例：
acos(0.5) = 1.0471975511965976acosh(X: integer | float) -> float
X の双曲線アークコサイン（ラジアン単位）を返します。X は1以上でなければなりません。例：
acosh(1.5) = 0.9624236501192069asin(X: integer | float) -> float
X のアークサイン（ラジアン単位）を返します。X の範囲は [-1, 1] です。例：
asin(0.5) = 0.5235987755982988asinh(X: integer | float) -> float
X の双曲線アークサインを返します。例：
asinh(0.5) = 0.48121182505960347atan(X: integer | float) -> float
X のアークタンジェント（ラジアン単位）を返します。例：
atan(0.5) = 0.46364760900080615atanh(X: integer | float) -> float
X の双曲線アークタンジェントを返します。X は (-1, 1) の範囲です。例：
atanh(0.5) = 0.5493061443340549ceil(X: integer | float) -> integer
X 以上の最小の整数に切り上げます。例：
ceil(0.8) = 1cos(X: integer | float) -> float
角度 X（ラジアン単位）のコサインを返します。例：
cos(0.5) = 0.8775825618903728cosh(X: integer | float) -> float
X の双曲線コサインを返します。例：
cosh(0.5) = 1.1276259652063807exp(X: integer | float) -> float
自然対数の底 e の X 乗を返します。例：
exp(1) = 2.718281828459045floor(X: integer | float) -> integer
X 以下の最大の整数を返します。例：
floor(3.6) = 3fmod(X: integer | float, Y: integer | float) -> float
X を Y で割った余りを浮動小数点数で返します。例：
fmod(6.5, 2.5) = 1.5log(X: integer | float) -> float
X の自然対数を返します。X は0より大きくなければなりません。例：
log(7.38905609893065) = 2.0log10(X: integer | float) -> float
X の常用対数（底10の対数）を返します。X は0より大きくなければなりません。例：
log10(100) = 2.0log2(X: integer | float) -> float
X の底2の対数を返します。X は0より大きくなければなりません。例：
log2(8) = 3.0
log2(8.5) = 3.0874628412503395round(X: integer | float) -> integer
X を最も近い整数に丸めます。例：
round(4.5) = 5power(X: integer | float, Y: integer | float) -> float
X の Y 乗を返します。例：
power(2, 3) = 8.0random() -> float
[0, 1) の範囲のランダムな浮動小数点数を返します。例：
random() = 0.5400050092601868sin(X: integer | float) -> float
角度 X（ラジアン単位）のサインを返します。例：
sin(0.5) = 0.479425538604203sinh(X: integer | float) -> float
X の双曲線サインを返します。例：
sinh(0.5) = 0.5210953054937474sqrt(X: integer | float) -> float
X の平方根を返します。例：
sqrt(9) = 3.0tan(X: integer | float) -> float
角度 X（ラジアン単位）のタンジェントを返します。例：
tan(0.5) = 0.5463024898437905tanh(X: integer | float) -> float
X の双曲線タンジェントを返します。例：
tanh(0.5) = 0.46211715726000974データ型判定関数
データ型判定関数は、指定したフィールドのデータ型を判定し、そのフィールドが指定したデータ型に合致するかどうかを真偽値で示します。
is_array(Term: any) -> boolean
'any' はすべてのデータ型を意味します。
Term が配列型かどうか判定します。例：
is_array([1, 2]) = true
is_array(json_decode('[{"value": 1}]')) = true
is_array(json_decode('{"value": 1}')) = false
is_array(0.5) = false
is_array('[1, 2]') = falseis_bool(Term: any) -> boolean
Term がブール型かどうか判定します。例：
is_bool(true) = true
is_bool(false) = false
is_bool('true') = falseis_float(Term: any) -> boolean
Term が浮動小数点型かどうか判定します。例：
is_float(123.4) = true
is_float(123) = falseis_int(Term: any) -> boolean
Term が整数型かどうか判定します。例：
is_int(123) = true
is_int(123.4) = falseis_map(Term: any) -> boolean
Term がマップ型かどうか判定します。例：
is_map(json_decode('{"value": 1}')) = true
is_map(json_decode('[{"value": 1}]')) = falseis_null(Term: any) -> boolean
変数 Term が未定義かどうか判定します。この関数は変数に値が割り当てられているかどうかを判定するために使いますが、値がJSONの null であっても未定義とはみなしません。
例：
is_null(this_is_an_unassigned_variable) = true
is_null(map_get('b', json_decode('{"a": 1}'))) = true
is_null(map_get('b', json_decode('{"b": null}'))) = falseis_null_var(Term: any) -> boolean
変数 Term が未定義または null かどうか判定します。例：
is_null_var(this_is_an_unassigned_variable) = true
is_null_var(map_get('b', json_decode('{"a": 1}'))) = true
is_null_var(map_get('b', json_decode('{"b": null}'))) = trueis_not_null_var(Term: any) -> boolean
is_null_var の逆で、変数 Term が定義されていてかつ null でないか判定します。
is_num(Term: any) -> boolean
Term が整数型または浮動小数点型かどうか判定します。例：
is_num(123) = true
is_num(123.4) = true
is_num('123') = falseis_str(Term: any) -> boolean
Term が文字列型かどうか判定します。例：
is_str('123') = true
is_str(123) = falseis_empty(Array or Map) -> boolean
Array または Map が空かどうか判定します。例：
is_empty(json_decode('{}')) = true
is_empty('{}') = true
is_empty('{"key" : 1}') = false
is_empty(map_get('key', '{"key" : []}')) = true
is_empty(map_get('key', '{"key" : [1}')) = falseデータ型変換関数
bool(Term: boolean | integer | string) -> boolean
Term をブール型に変換します。Term はブール型、0または1の整数型、または文字列型で true または false のいずれかでなければなりません。
例：
# 正しい例
bool(true) = true
bool(0) = false
bool('false') = false
# 間違い例
bool(20)
bool('True')float(Term: float | integer | string) -> float
Term を浮動小数点数に変換します。
Term が文字列型の場合、科学的記数法が利用可能です。例えば float('3.14e4') のように記述できます。浮動小数点型は最大16桁の有効数字をサポートします。文字列 Term が表す浮動小数点数の有効数字が16桁を超える場合、変換時に丸め誤差が発生する可能性があります。
例：
float(20) = 20.0
float('3.14') = 3.14
float('3.14e4') = 31400
float('3.14e+4') = 31400
float('3.14e-4') = 0.000314
float('3.14E-4') = 0.000314
# 有効数字が16桁を超えると丸め誤差により異なる入力が同じ出力になることがある
float('0.12345678901234566') = 0.12345678901234566
float('0.12345678901234567') = 0.12345678901234566float(Term: float | integer | string, Decimals: integer) -> float
Term を小数点以下最大 Decimals 桁の浮動小数点数に変換します。Decimals の範囲は (0, 253] です。その他の挙動は float/1 と同じです。例：
float('3.1415926', 3) = 3.142
float('0.000012345', 5) = 0.00001float2str(Float: float, Decimals: integer) -> string
浮動小数点数 Float を文字列に変換します。小数点以下最大 Decimals 桁まで含み、末尾のゼロは切り捨てられます。Decimals の範囲は [0, 253] です。Float の有効数字が16桁を超える場合、変換時に丸め誤差が発生する可能性があります。
浮動小数点数はコンピュータ上で正確に格納できないため、Decimals が Float の小数点以下の桁数（先行ゼロも含む）より大きい場合、float2str は Float の2進近似値の10進表現を返すことがあります。
例：
float2str(0.1, 5) = '0.1'
float2str(0.1, 20) = '0.10000000000000000555'
float2str(0.1, 25) = '0.1000000000000000055511151'
float2str(0.00000000001, 20) = '0.00000000001'
# 末尾のゼロは切り捨てられる
float2str(0.100001, 5) = '0.1'
# 有効数字が16桁を超えると丸め誤差により異なる入力が同じ出力になることがある
float2str(123456789.01234565, 8) = '123456789.01234566'
float2str(123456789.01234566, 8) = '123456789.01234566'int(Term: boolean | float | integer | string) -> integer
Term を整数に変換します。
Termがブール型の場合、trueは1、falseは0に変換されます。Termが浮動小数点型の場合、Termは切り捨てられ、Term以下の最大の整数に変換されます。Termが文字列型の場合、少なくとも1つの数字文字を含み、先頭に単一の+または-を付けることができ、先頭のゼロは無視されます。数学的表記もサポートされます。Termが整数型の場合、そのまま返されます。
例：
# 正しい例
int(true) = 1
int(3.14) = 3
int(-3.14) = 4
int('-100') = -100
int('+200') = 200
int('0010') = 10
int('3.1415e2') = 314
int(substr('Number 100', 7)) = 100
# 間違い例
int('-100+200')
int('Number 100')str(Term: any) -> string
任意の型の Term を文字列に変換します。
Termがマップまたは配列の場合、str関数はTermをJSONエンコードしようとします。Termが浮動小数点数の場合、str関数は対応する文字列を返し、末尾のゼロは切り捨てられます。返される文字列は小数点以下最大10桁まで保持します。より多くの小数点以下桁数を返すにはfloat2str関数を使用してください。
例：
str(100) = '100'
str(nth(1, json_decode('[false]'))) = 'false'
str(json_decode({"msg": "hello"})) = '{"msg":"hello"}'
str(json_decode('[{"msg": "hello"}]')) = '[{"msg":"hello"}]'
# 末尾のゼロは切り捨てられる
# 小数点以下最大10桁を保持
str(0.30000000040) = '0.3000000004'
str(0.30000000004) = '0.3'
# 小数点以下10桁で丸められる
# 11桁目以降で丸め
str(3.14159265359) = '3.1415926536'
str(0.000000314159265359) = '0.0000003142'str_utf8(Term: any) -> string
任意の Term をUTF-8エンコードされた文字列に変換します。
その他の挙動は str(Any) と同一です。
str_utf8(100) = '100'
str_utf8(nth(1, json_decode('[false]'))) = 'false'
str_utf8(json_decode({"msg": "hello"})) = '{"msg":"hello"}'
str_utf8(json_decode('[{"msg": "hello"}]')) = '[{"msg":"hello"}]'
# 末尾のゼロは切り捨てられる
# 小数点以下最大10桁を保持
str_utf8(0.30000000040) = '0.3000000004'
str_utf8(0.30000000004) = '0.3'
# 小数点以下10桁で丸められる
# 11桁目以降で丸め
str_utf8(3.14159265359) = '3.1415926536'
str_utf8(0.000000314159265359) = '0.0000003142'str_utf16_le(Term: any) -> binary
任意の Term をUTF-16リトルエンディアンエンコードされたバイナリ文字列に変換します。
TIP
UTF-16リトルエンディアンエンコード文字列はJSONオブジェクト内で正しく表示されないことがあります。EMQXでは通常バイナリデータとして扱われます。読みやすい16進数文字列に変換するには bin2hexstr 関数を使用してください。
このエンコードはMicrosoft SQL ServerのようなリトルエンディアンUTF-16を使用するシステムで一般的に使われます。
# Unicodeの `h`:
# | h(\u68) |
# | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 1 | 1 | 0 | 1 | 0 | 0 | 0 | (ビッグエンディアン)
# | 0x00 | 0x68 |
# | 0 | 1 | 1 | 0 | 1 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | 0 | (リトルエンディアン)
# | 0x68 | 0x00 |
str_utf16_le('h') = 'h\u0000'
bin2hexstr(str_utf16_le('hello')) = '680065006C006C006F00'文字列操作関数
文字列関数は大文字・小文字変換、空白除去、部分文字列抽出、置換、エスケープ／アンエスケープなどの操作に使用できます。
ascii(Char: string) -> integer
文字 Char に対応するASCIIコードを返します。Char が複数文字の場合は最初の1文字のコードのみ返します。例：
ascii('a') = 97
ascii('abc') = 97concat(Str1: string, Str2: string) -> string
Str1 と Str2 を連結して1つの文字列にします。例：
concat('Name:', 'John') = 'Name:John'find(String: string, SearchPattern: string) -> string
String 内で部分文字列 SearchPattern を検索し、SearchPattern より前のすべての内容を削除して残りの文字列を返します。SearchPattern が見つからない場合は空文字列を返します。この関数は find(String, SearchPattern, 'leading') と同等です。
例：
find('..., Value: 1.2', 'Value:') = 'Value: 1.2'
find('..., Value: 1.2', 'Data') = ''find(String: string, SearchPattern: string, Direction: string) -> string
find/2 と同様ですが、Direction で部分文字列 SearchPattern の検索方向を指定できます。例：
find('Front, Middle, End', ', ', 'leading') = ', Middle, End'
find('Front, Middle, End', ', ', 'trailing') = ', End'join_to_string(Sep: string, Array: array) -> string
Array の要素を区切り文字 Sep で連結して1つの文字列にします。例：
join_to_string(', ', ['a', 'b', 'c']) = 'a, b, c'lower(String: string) -> string
文字列 String の大文字を小文字に変換します。例：
lower('Hello') = 'hello'ltrim(String: string) -> string
trim/1 と同様ですが、String の先頭の空白文字のみを削除します。例：
ltrim('\t hello \n') = 'hello \n'
ltrim('\t hello \r\n') = 'hello \r\n'pad(String: string, Length: integer) -> string
String の末尾にスペースを埋めて指定長さ Length にします。例：
pad('hello', 8) = 'hello 'pad(String: string, Length: integer, Direction: string) -> string
pad/2 と同様ですが、Direction で埋める方向を指定できます。leading は前方にスペースを埋め、trailing は後方に、both は前後両方に埋めます。
both 指定時に埋めるスペース数が奇数の場合、最後のスペースは後方に埋められます。
例：
pad('hello', 8, 'leading') = ' hello'
pad('hello', 8, 'trailing') = 'hello '
pad('hello', 8, 'both') = ' hello 'pad(String: string, Length: integer, Direction: string, Char: string) -> string
pad/3 と同様ですが、指定したグラフェムクラスタ Char で埋めることができます。
ルールエンジンは Char が合法的なグラフェムクラスタかどうかをチェックしないため、Char が何文字であっても1文字分として扱われます。例：
pad('hello', 8, 'trailing', '!') = 'hello!!!'
pad('hello', 8, 'trailing', '\r\n') = 'hello\r\n\r\n\r\n'
pad('hello', 8, 'trailing', 'abc') = 'helloabcabcabc'regex_match(String: string, Expression: string) -> boolean
文字列 String が正規表現 Expression にマッチするか判定します。例：
regex_match('123', '^\d+$') = true
regex_match('a23', '^\d+$') = falseregex_replace(String: string, Expression: string, Replacement: string) -> string
文字列 String の正規表現 Expression にマッチした部分を文字列 Replacement に置換します。マッチしない場合は元の String を返します。例：
regex_replace('hello 123', '\d+', 'world') = 'hello world'
regex_replace('a;b; c', ';\s*', ',') = 'a,b,c'regex_extract(String: string, Expression: string) -> [string]
TIP
この関数はEMQX v5.7.1以降で導入されました。
この関数は、与えられた文字列に対してキャプチャグループ付きの正規表現パターンを非グローバル検索します。完全一致部分を除き、キャプチャグループにマッチした部分を抽出できます。
マッチがあれば、すべてのキャプチャグループをリストで返します。マッチがなければ空リストを返します。
例：
regex_extract('Number: 12345', '(\d+)') -> ['12345']
regex_extract('Hello, world!', '(\w+).*\s(\w+)') -> ['Hello', 'world']
regex_extract('No numbers here!', '(\d+)') -> []
regex_extract('Date: 2021-05-20', '(\d{4})-(\d{2})-(\d{2})') -> ['2021', '05', '20']replace(String: string, SearchPattern: string, Replacement: string) -> string
String 内のすべての SearchPattern を Replacement に置換します。例：
replace('ab..cd..ef', '..', '**') = 'ab**cd**ef'
replace('ab..cd..ef', '..', '') = 'abcdef'replace(String: string, SearchPattern: string, Replacement: string, Where: string) -> string
String 内の SearchPattern を Replacement に置換します。
Where の値は以下の通りです。
all: すべてのSearchPatternを置換（replace/3と同等）leading: 先頭のSearchPatternのみ置換trailing: 末尾のSearchPatternのみ置換
例：
replace('ab..cd..ef', '..', '**', 'all') = 'ab**cd**ef'
replace('ab..cd..ef', '..', '**', 'leading') = 'ab**cd..ef'
replace('ab..cd..ef', '..', '**', 'trailing') = 'ab..cd**ef'reverse(String: string) -> string
文字列を逆順にします。例：
reverse('hello') = 'olleh'rm_prefix(String: string, Prefix: string) -> string
文字列 String の先頭にある接頭辞 Prefix を削除します。String が Prefix で始まらない場合は元の文字列を返します。例：
rm_prefix('foo/bar', 'foo/') = 'bar'
rm_prefix('foo/bar', 'xxx/') = 'foo/bar'rtrim(String: string) -> string
trim/1 と同様ですが、String の末尾の空白文字のみを削除します。例：
rtrim('\t hello \n') = '\t hello'
rtrim('\t hello \r\n') = '\t hello'split(String: string, Separator: string) -> array
String を区切り文字 Separator で分割し、部分文字列の配列を返します。
2つ以上連続した区切り文字は1つとはみなされず、分割結果に空文字列が含まれることがあります。split/2 はデフォルトで結果をトリムし空文字列を除外します。空文字列を残したい場合は split(String, Separator, 'notrim') を使ってください。
区切り文字は複数文字で構成可能ですが、1つのまとまりとして扱われます。複数の区切り文字を同時に指定したい場合は tokens 関数を使ってください。
例：
split('a;', ';') = ['a']
split('a;b;c', ';') = ['a', 'b', 'c']
split('a;;b;;c', ';') = ['a', 'b', 'c']
# Howell Wiseの前の空白に注意
split('Sienna Blake; Howell Wise', ';') = ['Sienna Blake', ' Howell Wise']
split('Sienna Blake; Howell Wise', '; ') = ['Sienna Blake', 'Howell Wise']split(String: string, Separator: string, Option: string) -> array
split/2 と同様ですが、Option で処理する区切り文字の位置や空文字列の返却有無を指定できます。
Option の値は以下の通りです。
notrim: 文字列中のすべての区切り文字を処理し、空文字列を含む結果を返すleading: 先頭の区切り文字のみ処理し、空文字列を含まない結果を返すleading_notrim: 先頭の区切り文字のみ処理し、空文字列を含む結果を返すtrailing: 末尾の区切り文字のみ処理し、空文字列を含まない結果を返すtrailing_notrim: 末尾の区切り文字のみ処理し、空文字列を含む結果を返す
例：
split('a;;b;;c', ';', 'notrim') = ['a', '', 'b', '', 'c']
split('a;b;c', ';', 'leading') = ['a', 'b;c']
split('a;b;c', ';', 'trailing') = ['a;b', 'c']
split(';a;b;c', ';', 'leading_notrim') = ['', 'a;b;c']
split('a;b;c;', ';', 'trailing_notrim') = ['a;b;c', '']sprintf(Format, ...) -> string
Format に従ってフォーマットされた文字列を返します。Format 文字列には通常の文字とフォーマット用の制御シーケンスが含まれます。
制御シーケンスの形式は一般に ~F.P.PadModC です。
文字 C は制御シーケンスの種類を決定し、必須項目です。F、P、Pad、Mod はすべて任意です。詳細は https://www.erlang.org/doc/man/io.html#fwrite-1 を参照してください。
例：
sprintf('hello, ~s!', 'steve') = 'hello, steve!'
sprintf('count: ~p~n', 100) = 'count: 100\n'strlen(String: string) -> integer
String の長さを返します。例：
strlen('hello') = 5
strlen('hello\n') = 6substr(String: string, Start: integer) -> string
String の位置 Start から末尾までのすべての文字を返します。文字列の添字は0始まりで、例えば文字列 "hello" の位置0は "h" です。例：
substr('hello', 0) = 'hello'
substr('hello world', 6) = 'world'substr(String: string, Start: integer, Length: integer) -> string
String の位置 Start から最大長さ Length の部分文字列を返します。添字は0始まりです。例：
substr('hello world!', 6, 5) = 'world'tokens(String: string, SeparatorList: string) -> array
String を SeparatorList に含まれる文字で分割し、部分文字列のリストを返します。
2つ以上連続した区切り文字は1つとして扱われ、空文字列は発生しません。
例：
tokens('a,b;c,d', ',;') = ['a', 'b', 'c', 'd']
tokens('a;;b', ';') = ['a', 'b']tokens(String: string, SeparatorList:string, NoCRLF: string) -> array
tokens/2 と同様ですが、NoCRLF に nocrlf を指定すると改行コード（CR、LF）も同時に分割対象にできます。例：
tokens('a\rb\nc\r\nd', ';', 'nocrlf') = ['a', 'b', 'c', 'd']trim(String: string) -> string
String の先頭と末尾から空白文字（スペース、タブ、フォームフィード、改行など）を削除します。\r\n はUnicode標準でグラフェムクラスタとみなされるため、\r\n はまとめて削除されます。例：
trim('\t hello \n') = 'hello'
trim('\t hello \r\n') = 'hello'unescape(String: string) -> string
エスケープシーケンスを元の文字に戻します。SQL内でエスケープシーケンスを使う場合は、正しく処理するためにこの関数でアンエスケープしてください。
TIP
この関数はEMQX v5.7.0以降で導入されました。
例えば、ペイロードが改行区切りの文字列の場合：
32A48702-1FA6-4E7C-97F7-8EA3EA48E8A3
87.2
12.3
my-device\n でペイロードを分割したい場合、以下のSQLは期待通りに動作しません。
SELECT split(payload, '\n') as device_info FROM 't/#'出力結果：
{
"device_info": [
"32A48702-1FA6-4E7C-97F7-8EA3EA48E8A3\n87.2\n12.3\nmy-device"
]
}unescape 関数で \n をアンエスケープすると期待通りの結果が得られます。
SELECT split(payload, unescape('\n')) as device_info FROM 't/#'出力結果：
{
"device_info": [
"32A48702-1FA6-4E7C-97F7-8EA3EA48E8A3",
"87.2",
"12.3",
"my-device"
]
}unescape関数は以下のエスケープシーケンスをサポートします：
標準Cエスケープシーケンス：
\n：改行（LF）\t：水平タブ（HT）\r：復帰（CR）\b：バックスペース（BS）\f：フォームフィード（FF）\v：垂直タブ（VT）\'：シングルクォート（'）\"：ダブルクォート（"）\\：バックスラッシュ（\）\?：クエスチョンマーク（?）\a：アラート（ベル、BEL）
16進エスケープコード：
\xH...：H...は1文字以上の16進数（0-9, A-F, a-f）で、任意のutf32文字をエンコード可能。
認識されないエスケープシーケンスや無効なUnicode文字を形成する16進エスケープは例外をスローします。
upper(String: string) -> string
String の小文字を大文字に変換します。例：
upper('hello') = 'Hello'マップ操作関数
map_get(Key: string, Map: map) -> any
Map 内の指定された Key の値を返します。Key が存在しない場合は undefined を返します。例：
map_get('msg', json_decode('{"msg": "hello"}')) = 'hello'
map_get('data', json_decode('{"msg": "hello"}')) = undefinedmap_get(Key: srting, Map: map, Default: any) -> any
map_get/2 と同様ですが、Key が存在しない場合は指定した Default を返します。例：
map_get('data', json_decode('{"msg": "hello"}'), '') = ''
map_get('value', json_decode('{"data": [1.2, 1.3]}'), []) = []map_keys(Map: map) -> array
Map 内のすべてのキーの配列を返します。例：
map_keys(json_decode('{"a": 1, "b": 2}')) = ['a', 'b']map_put(Key: string, Value: any, Map: map) -> map
Map に Key と関連付けられた Value を挿入し、更新されたマップを返します。Key が既に存在する場合は古い値を新しい Value に置き換えます。例：
map_get('b', map_put('b', 1, json_decode('{"a": 1}'))) = 1
map_get('a', map_put('a', 2, json_decode('{"a": 1}'))) = 2map_to_redis_hset_args(Map) -> list
TIP
この関数はEMQX v5.7.1以降で導入されました。
マップをRedisの HSET（または HMSET）コマンド用のフィールド名と値のリストに変換します。
例えば、SELECT map_to_redis_hset_args(payload.value) as hset_fields FROM t/1 のように指定し、hset_fields 変数をRedisアクションのコマンドテンプレート HMSET name1 ${hset_fields} に組み込むことができます。
例えば payload.value がマップ {"a" : 1, "b": 2} の場合、生成されるコマンドは HMSET name1 b 2 a 1 のようになります。マップ内のフィールドの順序は非決定的です。
map_to_entries(Map: map) -> array
Map を key と value フィールドを持つオブジェクトの配列に変換します。例：
map_to_entries(json_decode('{"a": 1, "b": 2}')) = [{"key": "a", "value": 1},{"key": "b", "value": 2}]map_values(Map: map) -> array
Map 内のすべての値の配列を返します。例：
map_values(json_decode('{"a": 1, "b": 2}')) = [1, 2]mget(Key: string | array, Map: map) -> any
Map 内の指定された Key の値を返します。Key が存在しない場合は undefined を返します。配列を使って複数のキーを指定し、ネストされたマップから関連する値を取得できます。例：
mget('c', json_decode('{"a": {"b": 1}}')) = undefined
json_decode(mget('a', json_decode('{"a": {"b": 1}}'))) = '{"b": 1}'
mget(['a', 'b'], json_decode('{"a": {"b": 1}}')) = 1mput(Key: string | array, Value: any, Map: map) -> map
Map に Key と関連付けられた Value を挿入し、更新されたマップを返します。Key が既に存在する場合は古い値を新しい値に置き換えます。配列を使って複数のキーを指定し、ネストされたマップにデータを挿入できます。例：
mget(['a', 'b'], mput(['a', 'b'], 2, json_decode('{"a": {"b": 1}}'))) = 2
mget(['a', 'b'], mput(['a', 'b'], 2, json_decode('{"c": 1}'))) = 2map_size(Map: map) -> any
Map のキー数を返します。例：
map_size(json_decode('{}')) = 0
map_size(json_decode('{"msg": "hello"}')) = 1配列操作関数
contains(Item: any, Array: array) -> boolean
配列 Array に指定した Item が含まれているか判定します。例：
contains(2, [1, 2, 3]) = true
contains(2.3, [1.8, 2.5, 2.0]) = false
contains('John', ['John', 'David']) = true
contains([1, 2], [a, b, [1, 2]]) = true
contains(json_decode('{"a": 1}'), [json_decode('{"a": 1}'), json_decode('{"b": 2}')]) = truefirst(Array: array) -> any
配列 Array の最初の要素を返します。Array は空であってはいけません。例：
# 正しい例
first(['John', 'David']) = 'John'
# 間違い例
first([])last(Array: array) -> any
配列 Array の最後の要素を返します。Array は空であってはいけません。例：
# 正しい例
last(['John', 'David']) = 'David'
# 間違い例
last([])length(Array: array) -> integer
配列 Array の長さ（要素数）を返します。例：
length([1,2,3,4]) = 4
length([]) = 0nth(N: integer, Array: array) -> any
配列 Array のN番目の要素を返します。N は Array の長さを超えてはいけません。例：
# 正しい例
nth(1, [1,2,3]) = 1
# 間違い例
nth(0, [1,2,3])
nth(4, [1,2,3])sublist(Length: integer, Array: array) -> any
配列 Array の先頭から最大長さ Length の部分配列を返します。Length が Array の長さより大きい場合は全体を返します。例：
sublist(3, [1,2,3,4]) = [1,2,3]
sublist(10, [1,2,3,4]) = [1,2,3,4]sublist(Start: integer, Length: integer, Array:array) -> any
sublist/2 と同様ですが、Start で返す要素の開始位置を指定できます。Start + Length が Array の長さを超える場合は全体を返します。例：
sublist(2, 10, [1,2,3,4]) = [2,3,4]ハッシュ関数
md5(String: string) -> string
任意長の文字列 String に対して128ビット固定長のMD5ハッシュ値を計算します。ハッシュ値は32桁の16進数文字列で返され、小文字（a～f）で固定されます。
例：
md5('hello') = '5d41402abc4b2a76b9719d911017c592'sha(String: string) -> string
任意長の文字列 String に対して160ビット固定長のSHA-1ハッシュ値を計算します。ハッシュ値は40桁の16進数文字列で返され、小文字（a～f）で固定されます。
例：
sha('hello') = 'aaf4c61ddcc5e8a2dabede0f3b482cd9aea9434d'sha256(String: string) -> string
任意長の文字列 String に対して256ビット固定長のSHA-2ハッシュ値を計算します。ハッシュ値は64桁の16進数文字列で返され、小文字（a～f）で固定されます。
例：
sha256('hello') = '2cf24dba5fb0a30e26e83b2ac5b9e29e1b161e5c1fa7425e73043362938b9824'圧縮・解凍関数
注：バイナリデータは直接JSONエンコードできないため、16進数文字列に変換するには bin2hexstr 関数を呼び出す必要があります。
gunzip(Data: binary) -> binary | string
Data を解凍します。Data はgzヘッダーと末尾にチェックサムを含む必要があります。例：
gunzip(hexstr2bin('1F8B0800000000000013CB48CDC9C9070086A6103605000000')) = 'hello'gzip(Data: binary | string) -> binary
DEFLATEアルゴリズムで Data を圧縮し、返される圧縮結果はgzヘッダーと末尾のチェックサムを含みます。例：
bin2hexstr(gzip('hello')) = '1F8B0800000000000013CB48CDC9C9070086A6103605000000'unzip(Data: binary) -> binary | string
Data を解凍します。Data はzlibヘッダーと末尾のチェックサムを含まない必要があります。例：
unzip(hexstr2bin('CB48CDC9C90700')) = 'hello'zip(Data: binary | string) -> binary
DEFLATEアルゴリズムで Data を圧縮し、返される圧縮結果はzlibヘッダーと末尾のチェックサムを含みません。例：
bin2hexstr(zip('hello')) = 'CB48CDC9C90700'zip_compress(Data: binary | string) -> binary
DEFLATEアルゴリズムで Data を圧縮します。返される圧縮結果はzlibヘッダーと末尾のチェックサムを含みます。例：
bin2hexstr(zip_compress('hello')) = '789CCB48CDC9C90700062C0215'zip_uncompress(Data: binary) -> binary | string
Data を解凍します。Data はzlibヘッダーと末尾のチェックサムを含む必要があります。例：
zip_uncompress(hexstr2bin('789CCB48CDC9C90700062C0215')) = 'hello'ビット演算関数
bitand(Num1: integer, Num2: integer) -> integer
Num1 と Num2 のビットごとのAND演算結果を返します。入力と出力は符号付き整数です。例：
bitand(10, 8) = 8
bitand(-10, -8) = -16bitnot(Num: integer) -> integer
Num のビットごとの否定演算結果を返します。入力と出力は符号付き整数です。例：
bitnot(10) = -11
bitnot(-12) = 11bitsl(Num: integer, Shift: integer) -> integer
Num をビット単位で左に Shift ビットシフトし、右端を0で埋めます。例：
bitsl(8, 2) = 32
bitsl(-8, 2) = -32bitsr(Num: integer, Shift: integer) -> integer
Num をビット単位で右に Shift ビットシフトし、左端を符号ビットで埋めます（正数は0、負数は1）。例：
bitsr(8, 2) = 2
bitsr(8, 4) = 0
bitsr(-8, 2) = -2
bitsr(-8, 6) = -1bitor(Num1: integer, Num2: integer) -> integer
Num1 と Num2 のビットごとのOR演算結果を返します。例：
bitor(10, 8) = 10
bitor(-10, -8) = -2bitxor(Num1: integer, Num2: integer) -> integer
Num1 と Num2 のビットごとのXOR演算結果を返します。例：
bitxor(10, 8) = 2
bitxor(-10, -8) = 14ビット列操作関数
ルールエンジンはビット列操作用の関数を提供します。例えば subbits はビット列から指定長のビットを抽出し、指定したデータ型に変換します。
TIP
binary 型はバイト列を表し、各バイトは8ビットで構成されるため、バイナリのビット数は8の倍数でなければなりません。bitstring 型は任意のビット数のビット列を表します。
つまり、すべての binary は bitstring ですが、その逆は必ずしも真ではありません。
bitstring は長さが8の倍数でない場合、JSONなどの外部形式に直接シリアライズできません。
通常は整数などに変換する前の中間値として使われます。
bitsize(Bin: binary) -> integer
ビット列 Bin のビット数を返します。例：
bitsize('abc') = 24
bitsize('你好') = 48byteszie(Bin: binary) -> integer
バイト列 Bin のバイト数を返します。例：
byteszie('abc') = 3
byteszie('你好') = 6subbits(Bin: binary, BitNum: integer) -> integer
バイト列 Bin の先頭から長さ BitNum のビットを取得し、ビッグエンディアン順で符号なし整数に変換します。この関数は subbits(Bytes, 1, BitNum, 'integer', 'unsigned', 'big') と同等です。
例：
# 159 = 0x9F
subbits(hexstr2bin('9F4E58'), 8) = 159
# 40782 = 0x9F4E
subbits(hexstr2bin('9F4E58'), 16) = 40782
# bin2hexstr(base64_decode('n05Y')) = '9F4E58'
subbits(base64_decode('n05Y'), 8) = 159subbits(Bin: binary, Start: integer, BitNum: integer) -> integer
バイト列 Bin の位置 Start（1始まり）から長さ BitNum のビットを取得し、ビッグエンディアン順で符号なし整数に変換します。この関数は subbits(Bytes, Start, BitNum, 'integer', 'unsigned', 'big') と同等です。
例：
# 159 = 0x9F
subbits(hexstr2bin('9F4E58'), 1, 8) = 159
# 78 = 0x4E
subbits(hexstr2bin('9F4E58'), 9, 8) = 78
# bin2hexstr(base64_decode('n05Y')) = '9F4E58'
subbits(base64_decode('n05Y'), 9, 4) = 4subbits(Bin: binary, Start: integer, BitNum: integer, OutputType: string, Signedness: string, Endianness: string) -> bitstring | integer | float
バイト列 Bin の位置 Start（1始まり）から長さ BitNum のビットを取得し、指定されたバイト順 Endianness と符号属性 Signedness に従い、指定した型 OutputType に変換します。
OutputType の値：
- bits：bitstringの省略形
- integer
- float
Signedness の値：
- signed
- unsigned
Endianness の値：
- big
- little
OutputType が float の場合、Signedness は無効です。OutputType が bits の場合、Signedness と Endianness は無効です。
例：
# 40782 = 0x9F4E
subbits(hexstr2bin('9F4E58'), 1, 16, 'integer', 'unsigned', 'big') = 40782
subbits(hexstr2bin('9F4E58'), 1, 16, 'integer', 'signed', 'big') = -24754
# 20127 = 0x4E9F
subbits(hexstr2bin('9F4E58'), 1, 16, 'integer', 'unsigned', 'little') = 20127
subbits(hexstr2bin('9F4E58'), 1, 16, 'float', 'unsigned', 'big') = -0.00713348388671875
subbits(hexstr2bin('9F4E58'), 1, 16, 'float', 'signed', 'big') = -0.00713348388671875エンコード・デコード関数
base64_decode(Data: string) -> bytes | string
Data をbase64形式からデコードします。例：
base64_decode('aGVsbG8=') = 'hello'
bin2hexstr(base64_decode('y0jN')) = 'CB48CD'base64_encode(Data: binary | string) -> string
Data をbase64形式にエンコードします。例：
base64_encode('hello') = 'aGVsbG8='
base64_encode(hexstr2bin('CB48CD')) = 'y0jN'json_decode(Data: string) -> array | map
Data をJSON形式からデコードします。例：
map_get('a', json_decode('{"a": 1}')) = 1json_encode(Data: array | map) -> string
Data をJSON形式にエンコードします。例：
json_encode([1,2,3]) = '[1,2,3]'bin2hexstr(Data: binary) -> string
バイナリデータを対応する16進数文字列に変換します。例：
bin2hexstr(zip('hello')) = 'CB48CDC9C90700'hexstr2bin(Data: string) -> binary
16進数文字列を対応するバイナリデータに変換します。例：
unzip(hexstr2bin('CB48CDC9C90700')) = 'hello'sqlserver_bin2hexstr(Data: binary | string) -> string
任意のバイナリデータをMicrosoft SQL Serverのバイナリ型に変換します。0x プレフィックス付きのHEXエンコード文字列になります。
TIP
この関数はMicrosoft SQL Serverの CONVERT 関数と組み合わせて、UTF-8非対応のSQL ServerバージョンにUTF-16リトルエンディアンエンコードのUnicode文字列を書き込む際に利用できます。
sqlserver_bin2hexstr('hello') = '0x68656C6C6F'
sqlserver_bin2hexstr(str_utf16_le('hello')) = '0x680065006C006C006F00'
sqlserver_bin2hexstr(str_utf16_le('你好')) = '0x604F7D59'スキーマレジストリ関数
TIP
スキーマレジストリはEMQX Enterpriseエディションの機能です。
EMQX Enterpriseは、指定したスキーマに基づきProtobuf (Protocol Buffers)やAvroデータのエンコード・デコードを行う schema_encode および schema_decode 関数もサポートしています。詳細はスキーマレジストリを参照してください。
schema_encode(SchemaID: string, Data: map) -> binary
指定したAvroスキーマで Data をエンコードします。スキーマレジストリでスキーマを作成しIDを取得してください。
schema_encode(SchemaID: string, Data: map, MsgType: string) -> binary
指定したProtobufスキーマで Data をエンコードします。スキーマレジストリでスキーマを作成しIDを取得してください。MsgType はProtobufスキーマ内の Data に対応するメッセージタイプを指定します。
schema_decode(SchemaID: string, Bin: binary) -> map
指定したAvroスキーマで Bin をデコードします。スキーマレジストリでスキーマを作成しIDを取得してください。
schema_decode(SchemaID: string, Bin: binary, MsgType: string) -> map
指定したProtobufスキーマで Bin をデコードします。スキーマレジストリでスキーマを作成しIDを取得してください。MsgType はProtobufスキーマ内の Data に対応するメッセージタイプを指定します。
Sparkplug B関数
EMQX EnterpriseにはSparkplug Bメッセージのデコード・エンコード用の専用関数（sparkplug_decode と sparkplug_encode）もあります。詳細はSparkplug Bを参照してください。
日時変換関数
date_to_unix_ts(Unit: string, FormatString: string, DateTimeString: string) -> integer
日時文字列 DateTimeString をフォーマット文字列 FormatString に従って解析し、指定した時間単位 Unit のUnix時間に変換します。
利用可能な Unit は second、millisecond、microsecond、nanosecond です。
FormatString で利用可能なプレースホルダーは以下の通りです。
| プレースホルダー | 意味 | 値の範囲 | | ------ | ---------------------------------- | ----- ---------------- | | %Y | 4桁の年 | 0000 - 9999 | | %m | 2桁の月 | 01 - 12 | | %d | 2桁の日 | 01 - 31 | | %H | 24時間表記の2桁の時 | 00 - 24 | | %M | 2桁の分 | 00 - 59 | | %S | 2桁の秒 | 00 - 59 | | %N | ナノ秒 | 000000000 - 999999999 | | %6N | マイクロ秒（ナノ秒の最初の6桁） | 000000 - 999999 | | %3N | ミリ秒（ナノ秒の最初の3桁） | 000 - 999 | | %z | タイムゾーンオフセット（±hhmm形式） | -1159 - +1159 | | %:z | タイムゾーンオフセット（±hh:mm形式） | -11:59 - +11:59 | | %::z | タイムゾーンオフセット（±hh:mm:ss形式） | -11:59:59 - +11:59:59 |
例：
date_to_unix_ts('second', '%Y-%m-%d %H:%M:%S%:z', '2024-02-23 15:00:00+08:00') = 1708671600date_to_unix_ts(Unit: string, Offset: string | integer, FormatString: string, DateTimeString: string) -> integer
DateTimeString にタイムゾーンオフセットが含まれない場合、Offset で手動指定できます。その他の挙動は date_to_unix_ts/3 と同じです。Offset は文字列または秒数を表す整数で指定可能です。
文字列の場合、以下の形式をサポートします。
Zまたはz：UTCオフセット00:00±hh[:mm][:ss]または±hh[mm][ss]：UTCからの正負の時間オフセットlocal：システムのローカルタイムゾーンに対応するオフセット
例：
date_to_unix_ts('second', '+08:00', '%Y-%m-%d %H:%M:%S%:z', '2024-02-23 15:00:00') = 1708671600
date_to_unix_ts('second', 'Z', '%Y-%m-%d %H:%M:%S%:z', '2024-02-23 07:00:00') = 1708671600
date_to_unix_ts('second', 14400, '%Y-%m-%d %H:%M:%S%:z', '2024-02-23 15:00:00') = 1708686000format_date(Unit: string, Offset: string | integer, FormatString: string, Time: Integer) -> string
Unix時間 Time を指定フォーマットの日時文字列に変換します。Unit はUnix時間の単位、Offset は出力日時のタイムゾーンオフセット、FormatString は出力日時のフォーマットを表します。
date_to_unix_ts/3, 4 と同様の値を Unit、Offset、FormatString に指定可能です。
例：
format_date('millisecond', '+08:00', '%Y-%m-%d %H:%M:%S.%6N%z', 1708933353472) = '2024-02-26 15:42:33.472000+0800'
format_date('millisecond', '+08:00', '%Y-%m-%d %H:%M:%S.%6N%:z', 1708933353472) = '2024-02-26 15:42:33.472000+08:00'
format_date('millisecond', '+08:20:30', '%Y-%m-%d %H:%M:%S.%3N%::z', 1708933353472) = '2024-02-26 16:03:03.472+08:20:30'
format_date('millisecond', 'Z', '%Y-%m-%d %H:%M:%S.%3N%:z', 1708933353472) = '2024-02-26 07:42:33.472+08:00'
format_date('millisecond', 28800, '%Y-%m-%d %H:%M:%S.%3N%:z', 1708933353472) = '2024-02-26 15:42:33.472+08:00'now_rfc3339() -> string
現在のシステム時刻を秒単位のRFC3339形式の日時文字列で返します。例：
now_rfc3339() = '2024-02-23T10:26:20+08:00'now_rfc3339(Unit: string) -> string
now_rfc3339/0 と同様ですが、Unit で時間単位を指定できます。second、millisecond、microsecond、nanosecond をサポートします。例：
now_rfc3339('microsecond') = '2024-02-23T10:26:38.009706+08:00'now_timestamp() -> integer
現在のシステム時刻を秒単位のUnixタイムスタンプで返します。例：
now_timestamp() = 1708913853now_timestamp(Unit: string) -> integer
now_timestamp/0 と同様ですが、Unit で時間単位を指定できます。second、millisecond、microsecond、nanosecond をサポートします。例：
now_timestamp('microsecond') = 1708913828814315rfc3339_to_unix_ts(DateTimeString: string) -> integer
RFC3339準拠の日時文字列をUnixタイムスタンプに変換します。2024-02-23T15:56:30Z はUTCの2024年2月23日15時56分30秒を表します。
例：
rfc3339_to_unix_ts('2024-02-23T15:56:30Z') = 1708703790
rfc3339_to_unix_ts('2024-02-23T15:56:30+08:00') = 1708674990rfc3339_to_unix_ts(DateTimeString: string, Unit: string) -> integer
rfc3339_to_unix_ts/1 と同様ですが、返されるUnixタイムスタンプの単位を Unit で指定できます。second、millisecond、microsecond、nanosecond をサポートします。例：
rfc3339_to_unix_ts('2024-02-23T15:56:30.87Z', 'second') = 1708703790
rfc3339_to_unix_ts('2024-02-23T15:56:30.87Z', 'millisecond') = 1708703790870
rfc3339_to_unix_ts('2024-02-23T15:56:30.87Z', 'microsecond') = 1708703790870000
rfc3339_to_unix_ts('2024-02-23T15:56:30.535904509Z', 'nanosecond') = 1708703790535904509timezone_to_offset_seconds(Offset: string) -> integer
タイムゾーンオフセット文字列を秒数の整数に変換します。以下の形式をサポートします。
Zまたはz：UTCオフセット00:00±hh[:mm][:ss]または±hh[mm][ss]：UTCからの正負の時間オフセットlocal：システムのローカルタイムゾーンに対応するオフセット
例：
timezone_to_offset_seconds('Z') = 0
timezone_to_offset_seconds('+08:00') = 28800
timezone_to_offset_seconds('local') = 28800unix_ts_to_rfc3339(Time: integer) -> string
秒単位のUnixタイムスタンプをシステムのローカルタイムゾーンでRFC3339準拠の日時文字列に変換します。例：
unix_ts_to_rfc3339(1708671600) = '2024-02-23T15:00:00+08:00'unix_ts_to_rfc3339(Time: integer, Unit: string) -> string
unix_ts_to_rfc3339/0 と同様ですが、Unit で時間単位を指定できます。second、millisecond、microsecond、nanosecond をサポートします。例：
unix_ts_to_rfc3339(1708671600766, 'millisecond') = '2024-02-23T15:00:00.766+08:00'MongoDB日時関数
TIP
本節の関数はEMQX Enterpriseエディションのみ対象です。
mongo_date() -> MongoDB ISODate | string
現在時刻をMongoDBのISODate型または文字列で返します。MongoDB関連のアクションやSQLテストでのみサポートされ、SQLテストでは文字列を返します（例：ISODate("2024-02-23T15:00:00.123Z")）。mongo_date() から文字列以外の戻り値は他の関数の入力としては現在サポートされていません。
例：
mongo_date() = 'ISODate("2024-02-23T15:00:00.123Z")'mongo_date(Timestamp: integer) -> MongoDB ISODate | string
指定したミリ秒単位のUnixタイムスタンプをMongoDBのISODate型または文字列に変換します。その他の挙動は mongo_date/0 と同じです。
例：
mongo_date(now_timestamp('millisecond')) = 'ISODate(2024-02-23T15:48:57.871Z)'mongo_date(Timestamp: integer, Unit: string) -> MongoDB ISODate | string
指定したUnixタイムスタンプをMongoDBのISODate型または文字列に変換します。入力タイムスタンプの単位は Unit で指定できます。その他の挙動は mongo_date/0 と同じです。
Unit の値：
secondmillisecondmicrosecondnanosecond
例：
mongo_date(now_timestamp('microsecond'), 'microsecond') = 'ISODate(2024-02-23T15:51:01.232Z)'UUID関数
uuid_v4() -> string
バージョン4のUUIDを生成します。例：
uuid_v4() = 'f5bb7bea-a371-4df7-aa30-479add04632b'uuid_v4_no_hyphen() -> string
ハイフンなしのバージョン4 UUIDを生成します。例：
uuid_v4_no_hyphen() = 'd7a39aa4195a42068b962eb9a665503e'システム関数
getenv(Name)
環境変数 Name の値を返します。以下の制約があります。
- OS環境変数を読み取る際、
EMQXVAR_プレフィックスが付加されます。例えばgetenv('FOO_BAR')はEMQXVAR_FOO_BARを読み取ります。 - OS環境変数から読み込まれた値は不変です。
条件関数
coalesce(Value1: any, Value2: any) -> any
Value1 がnullの場合に Value2 を返します。
データフィールドがnullかどうかを判定し、デフォルト値に置き換えたい場合に便利です。
例えば、coalesce(payload.value, 0) は payload.value がnullでなければその値を返し、nullであれば 0 を返します。
SQL式の CASE WHEN is_null(payload.value) THEN 0 ELSE payload.value END と同等ですが、より簡潔です。
注意
EMQXルールSQLでは、null値の文字列表現はデフォルトで 'undefined' です。
coalesce_ne(Value1: any, Value2: any) -> any
coalesce と似ていますが、Value1 がnullまたは空文字列の場合に Value2 を返します。
注意
EMQXルールSQLでは、null値の文字列表現はデフォルトで 'undefined' です。