FluentD: условные операторы record_transformer

Как поставить условные операторы if else в fluentd record_transformerи добавить вывод в столбец.

например:

<filter nifi.*>
@type record_transformer
enable_ruby true
auto_typecast true
<record>
NormalizedFileInByte ${a=1024;if record[DataMetricIn]=="GB";record["FilesInByte"].to_f*a.to_f;else;record["FilesInByte"].to_f;end;}
</record>
</filter>


Я поместил оператор if else и добавил новый столбец NormalizedFileInByteв существующий журнал в приведенном выше примере. Но это ошибки.

Решение проблемы

это сработало для меня:

NormalizedFileInByte ${if record["message"].split(" ")[2].split(",")[0] == "PM"; record["message"].split(" ")[2].split(",")[0];end;