SINK

모든 tql 스크립트는 반드시 하나의 싱크(SINK) 함수로 끝나야 합니다.

기본 싱크 함수는 입력 레코드를 Machbase Neo 데이터베이스에 저장하는 INSERT()입니다. CHART()는 입력 레코드를 다양한 차트로 렌더링하고, JSON()과 CSV()는 입력 데이터를 각각 JSON·CSV 형식으로 인코딩합니다.

INSERT()

구문: INSERT( [bridge(),] columns..., table() [, tag()] )

INSERT()는 입력 레코드마다 INSERT 문을 실행해 지정한 데이터베이스 테이블에 저장합니다.

• bridge() bridge(’name’): 선택 옵션입니다.
• columns string: 컬럼 이름 목록입니다.
• table() table(’name’): 대상 테이블 이름을 지정합니다.
• tag() tag(’name’): 선택 옵션으로, 태그 테이블에만 사용할 수 있습니다.

1
2
3
4
5
6

FAKE(json({
    ["temperature", 1708582790, 23.45],
    ["temperature", 1708582791, 24.56]
}))
MAPVALUE(1, value(1)*1000000000) // convert epoch sec to nanosec
INSERT("name", "time", "value", table("example"))

1
2
3
4
5
6
7

FAKE(json({
    [1708582792, 32.34],
    [1708582793, 33.45]
}))
PUSHVALUE(0, "temperature")
MAPVALUE(1, value(1)*1000000000) // convert epoch sec to nanosec
INSERT("name","time", "value", table("example"))

1
2
3
4
5
6

FAKE(json({
    [1708582792, 32.34],
    [1708582793, 33.45]
}))
MAPVALUE(0, value(0)*1000000000) // convert epoch sec to nanosec
INSERT("time", "value", table("example"), tag('temperature'))

브리지로 연결한 외부 데이터베이스에 레코드를 삽입할 수도 있습니다.

1
2
3
4

INSERT(
    bridge("sqlite"),
    "company", "employee", "created_on", table("mem_example")
)

APPEND()

구문: APPEND( table() )

APPEND()는 Machbase Neo의 append 메서드로 입력 레코드를 지정한 데이터베이스 테이블에 저장합니다.

• table() table(string): 대상 테이블을 지정합니다.

1
2
3
4
5
6

FAKE(json({
    ["temperature", 1708582794, 12.34],
    ["temperature", 1708582795, 13.45]
}))
MAPVALUE(1, value(1)*1000000000 ) // convert epoch sec to nanosec
APPEND( table("example") )

CSV()

구문: CSV( [tz(), timeformat(), precision(), rownum(), heading(), delimiter(), nullValue(), binaryformat() ] )

결과 레코드를 CSV 형식으로 출력합니다. 각 레코드의 값이 CSV 행의 필드가 됩니다. 데이터의 끝은 마지막에 연속된 개행 문자 두 개(\n\n)로 구분합니다.

예를 들어 레코드가 {key: k, value:[v1,v2]}라면 CSV 레코드 v1,v2를 생성합니다.

• tz tz(name): 시간대, 기본값은 tz('UTC')입니다.
• timeformat timeformat(string): DATETIME 필드의 출력 형식, 기본값은 timeformat('ns')입니다.
• rownum rownum(boolean): 행 번호 컬럼을 추가합니다.
• precision precision(int): 부동소수점 필드의 정밀도입니다. precision(-1)은 제한 없음, precision(0)은 정수로 변환합니다.
• heading heading(boolean): 첫 행에 필드 이름을 추가합니다.
• delimiter delimiter(string): 기본값인 쉼표(,) 대신 사용할 필드 구분자를 지정합니다.
• nullValue(): NULL 값을 대체할 문자열을 지정합니다. 기본값은 nullValue('NULL')입니다. Since v8.0.14
• cache(): 결과 데이터를 캐시합니다. 자세한 내용은 결과 데이터 캐시를 참고해 주십시오. Since v8.0.43
• binaryformat() binaryformat(string): BINARY 컬럼의 출력 형식을 지정합니다. hex, base64, bytes, preview를 지원합니다. Since v8.5.2

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10)
CSV()

1,10
2,20
3,30

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10, "x10")
CSV( heading(true) )

x,x10
1,10
2,20
3,30

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10, "x10")
CSV( heading(true), delimiter("|") )

x|x10
1|10
2|20
3|30

1
2

FAKE( json({ ["A", 123], ["B", null], ["C", 234] }) )
CSV( nullValue("***") )

A,123
B,***
C,234

JSON()

구문: JSON( [transpose(), tz(), timeformat(), precision(), rownum(), rowsFlatten(), rowsArray(), binaryformat() ] )

레코드의 값으로 JSON 결과를 생성합니다.

• transpose transpose(boolean): 행과 열을 전치합니다. 대부분의 차트 라이브러리에서는 transpose(true)를 지정하는 편이 편리합니다.
• tz tz(name): 시간대, 기본값은 tz('UTC')입니다.
• timeformat timeformat(string): DATETIME 필드의 출력 형식, 기본값은 timeformat('ns')입니다.
• rownum rownum(boolean): 행 번호 컬럼을 추가합니다.
• precision precision(int): 부동소수점 필드의 정밀도입니다. precision(-1)은 제한 없음, precision(0)은 정수로 변환합니다.
• rowsFlatten rowsFlatten(boolean): JSON 객체의 rows 필드 배열 차원을 한 단계 줄입니다. JSON()에 transpose(true)와 rowsFlatten(true)를 함께 지정하면 rowsFlatten(true)는 무시되고 transpose(true)만 결과에 적용됩니다. Since v8.0.12
• rowsArray rowsArray(boolean): 각 레코드를 객체로 표현한 배열만 담은 JSON을 생성합니다. rowsArray(true)는 transpose(true)와 rowsFlatten(true)보다 우선합니다. Since v8.0.12
• cache(): 결과 데이터를 캐시합니다. 자세한 내용은 결과 데이터 캐시를 참고해 주십시오. Since v8.0.43
• binaryformat() binaryformat(string): BINARY 컬럼의 출력 형식을 지정합니다. hex, base64, bytes, preview를 지원합니다. Since v8.5.2

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10)
JSON()

{
    "data": {
        "columns": [ "x", "column" ],
        "types": [ "double", "double" ],
        "rows": [ [ 1, 10 ], [ 2, 20 ], [ 3, 30 ] ]
    },
    "success": true,
    "reason": "success",
    "elapse": "228.541µs"
}

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10, "x10")
JSON( transpose(true) )

{
    "data": {
        "columns": [ "x", "x10" ],
        "types": [ "double", "double" ],
        "cols": [ [ 1, 2, 3 ], [ 10, 20, 30 ] ]
    },
    "success": true,
    "reason": "success",
    "elapse": "121.375µs"
}

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10, "x10")
JSON( rowsFlatten(true) )

{
    "data": {
        "columns": [ "x", "x10" ],
        "types": [ "double", "double" ],
        "rows": [ 1, 10, 2, 20, 3, 30 ]
    },
    "success": true,
    "reason": "success",
    "elapse": "130.916µs"
}

1
2
3

FAKE( arrange(1, 3, 1))
MAPVALUE(1, value(0)*10, "x10")
JSON( rowsArray(true) )

{
    "data": {
        "columns": [ "x", "x10" ],
        "types": [ "double", "double" ],
        "rows": [ { "x": 1, "x10": 10 }, { "x": 2, "x10": 20 }, { "x": 3, "x10": 30 } ]
    },
    "success": true,
    "reason": "success",
    "elapse": "549.833µs"
}

NDJSON()

구문: NDJSON( [tz(), timeformat(), rownum(), binaryformat()] ) Since v8.0.33

레코드의 값으로 NDJSON 결과를 생성합니다.

NDJSON(Newline Delimited JSON)은 각 줄이 유효한 JSON 객체인 스트리밍용 JSON 데이터 형식입니다. JSON 객체를 한 번에 하나씩 처리할 수 있으므로 대용량 데이터셋이나 스트리밍 데이터를 처리할 때 유용합니다. 데이터의 끝은 마지막에 연속된 개행 문자 두 개(\n\n)로 구분합니다.

• tz tz(name): 시간대, 기본값은 tz('UTC')입니다.
• timeformat timeformat(string): DATETIME 필드의 출력 형식, 기본값은 timeformat('ns')입니다.
• rownum rownum(boolean): 행 번호 컬럼을 추가합니다.
• cache(): 결과 데이터를 캐시합니다. 자세한 내용은 결과 데이터 캐시를 참고해 주십시오. Since v8.0.43
• binaryformat() binaryformat(string): BINARY 컬럼의 출력 형식을 지정합니다. hex, base64, bytes, preview를 지원합니다. Since v8.5.2

1
2

SQL(`select * from example where name = 'neo_load1' limit 3`)
NDJSON(timeformat('Default'), tz('local'), rownum(true))

{"NAME":"neo_load1","ROWNUM":1,"TIME":"2024-09-06 14:46:19.852","VALUE":4.58}
{"NAME":"neo_load1","ROWNUM":2,"TIME":"2024-09-06 14:46:22.853","VALUE":4.69}
{"NAME":"neo_load1","ROWNUM":3,"TIME":"2024-09-06 14:46:25.852","VALUE":4.69}

MARKDOWN()

마크다운 또는 HTML 형식의 표를 생성합니다.

구문: MARKDOWN( [ options... ] )

• tz(string): 시간대, 기본값은 tz('UTC')입니다.
• timeformat(string): DATETIME 필드의 출력 형식, 기본값은 timeformat('ns')입니다.
• html(boolean): HTML 렌더러로 결과를 생성합니다. 기본값은 false입니다.
• rownum(boolean): 행 번호 컬럼을 표시합니다.
• precision precision(int): 부동소수점 필드의 정밀도입니다. precision(-1)은 제한 없음, precision(0)은 정수로 변환합니다.
• brief(boolean): 결과 행을 생략합니다. brief(true)는 briefCount(5)와 같습니다.
• briefCount(limit int): 레코드 수가 지정한 한도를 넘으면 결과 행을 생략합니다. 한도가 0이면 생략하지 않습니다.
• binaryformat() binaryformat(string): BINARY 컬럼의 출력 형식을 지정합니다. hex, base64, bytes, preview를 지원합니다. Since v8.5.2

1
2
3
4
5
6
7
8

FAKE( csv(`
10,The first line 
20,2nd line
30,Third line
40,4th line
50,The last is 5th
`))
MARKDOWN()

|column0 | column1 |
|:-------|:---------|
| 10     | The first line |
| 20     | 2nd line |
| 30     | Third line |
| 40     | 4th line |
| 50     | The last is 5th |

1
2
3
4
5
6
7
8

FAKE( csv(`
10,The first line 
20,2nd line
30,Third line
40,4th line
50,The last is 5th
`))
MARKDOWN( briefCount(2) )

|column0 | column1 |
|:-------|:---------|
| 10     | The first line |
| 20     | 2nd line |
| ...    | ...      |

> Total 5 records

1
2
3
4
5
6
7
8

FAKE( csv(`
10,The first line 
20,2nd line
30,Third line
40,4th line
50,The last is 5th
`))
MARKDOWN( briefCount(2), html(true) )

HTML()

구문: HTML(templates...) Since v8.0.52

제공한 템플릿으로 HTML 문서를 생성합니다.

자세한 사용법과 예제는 HTML 문서를 참고해 주십시오.

TEXT()

구문: TEXT(templates...) Since v8.0.52

제공한 템플릿으로 텍스트 문서를 생성합니다.

HTML()과 비슷하게 동작하지만 데이터에 HTML 이스케이프를 적용하지 않습니다.

DISCARD()

구문: DISCARD() Since v8.0.7

DISCARD()는 이름 그대로 모든 레코드를 조용히 버리므로 아무것도 출력하지 않습니다.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

FAKE( json({
    [ 1, "hello" ],
    [ 2, "world" ]
}))
WHEN( value(0) == 2, do( value(0), strToUpper(value(1)), {
    ARGS()
    WHEN( true, doLog("OUTPUT:", value(0), value(1)) )
    DISCARD()
}))
CSV()

CHART()

구문: CHART() Since v8.0.8

Apache ECharts로 차트를 생성합니다.

다양한 사용법은 CHART() 예제를 참고해 주십시오.