diff --git a/common/script/script-api/src/main/java/org/thingsboard/script/api/tbel/TbUtils.java b/common/script/script-api/src/main/java/org/thingsboard/script/api/tbel/TbUtils.java
index b337612011..bffd60f029 100644
--- a/common/script/script-api/src/main/java/org/thingsboard/script/api/tbel/TbUtils.java
+++ b/common/script/script-api/src/main/java/org/thingsboard/script/api/tbel/TbUtils.java
@@ -57,6 +57,8 @@ public class TbUtils {
                 List.class)));
         parserConfig.addImport("decodeToJson", new MethodStub(TbUtils.class.getMethod("decodeToJson",
                 ExecutionContext.class, List.class)));
+        parserConfig.addImport("decodeToJson", new MethodStub(TbUtils.class.getMethod("decodeToJson",
+                ExecutionContext.class, String.class)));
         parserConfig.addImport("stringToBytes", new MethodStub(TbUtils.class.getMethod("stringToBytes",
                 ExecutionContext.class, String.class)));
         parserConfig.addImport("stringToBytes", new MethodStub(TbUtils.class.getMethod("stringToBytes",
@@ -174,6 +176,9 @@ public class TbUtils {
     public static Object decodeToJson(ExecutionContext ctx, List<Byte> bytesList) throws IOException {
         return TbJson.parse(ctx, bytesToString(bytesList));
     }
+    public static Object decodeToJson(ExecutionContext ctx, String jsonStr) throws IOException {
+        return TbJson.parse(ctx, jsonStr);
+    }
 
     public static String bytesToString(List<Byte> bytesList) {
         byte[] bytes = bytesFromList(bytesList);
diff --git a/common/script/script-api/src/test/java/org/thingsboard/script/api/tbel/TbUtilsTest.java b/common/script/script-api/src/test/java/org/thingsboard/script/api/tbel/TbUtilsTest.java
index b6d5395af8..a16a70b962 100644
--- a/common/script/script-api/src/test/java/org/thingsboard/script/api/tbel/TbUtilsTest.java
+++ b/common/script/script-api/src/test/java/org/thingsboard/script/api/tbel/TbUtilsTest.java
@@ -27,6 +27,7 @@ import org.mvel2.SandboxedParserConfiguration;
 import org.mvel2.execution.ExecutionArrayList;
 import org.mvel2.execution.ExecutionHashMap;
 
+import java.io.IOException;
 import java.math.BigInteger;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
@@ -348,6 +349,24 @@ public class TbUtilsTest {
         Assert.assertEquals(0, Double.compare(doubleValRev, TbUtils.parseBytesToDouble(doubleVaList, 0, false)));
     }
 
+    @Test
+    public void parseBytesDecodeToJson() throws IOException {
+        String expectedStr = "{\"hello\": \"world\"}";
+        ExecutionHashMap<String, Object> expectedJson = new ExecutionHashMap<>(1, ctx);
+        expectedJson.put("hello", "world");
+        List<Byte> expectedBytes = TbUtils.stringToBytes(ctx, expectedStr);
+        Object actualJson =  TbUtils.decodeToJson(ctx, expectedBytes);
+        Assert.assertEquals(expectedJson,actualJson);
+    }
+    @Test
+    public void parseStringDecodeToJson() throws IOException {
+        String expectedStr = "{\"hello\": \"world\"}";
+        ExecutionHashMap<String, Object> expectedJson = new ExecutionHashMap<>(1, ctx);
+        expectedJson.put("hello", "world");
+        Object actualJson =  TbUtils.decodeToJson(ctx, expectedStr);
+        Assert.assertEquals(expectedJson,actualJson);
+    }
+
     private static List<Byte> toList(byte[] data) {
         List<Byte> result = new ArrayList<>(data.length);
         for (Byte b : data) {