fluvio-smartengine 0.50.1

The official Fluvio SmartEngine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

transforms:
  - uses: infinyon/jolt@0.4.1
    lookback:
      age: 1w
    with:
      spec:
        - operation: shift
          spec:
            payload:
              device: "device"
        - operation: default
          spec:
            device:
              type: "mobile"
  - uses: infinyon/jolt@0.4.1
    lookback:
      last: 1
    with:
      spec:
        - operation: shift
          spec:
            payload:
              device: "device"
        - operation: default
          spec:
            device:
              type: "mobile"
  - uses: infinyon/json-sql@0.2.1
    lookback:
      last: 10
      age: 12 s  
    with:
      mapping:
        table: "topic_message_demo"
        map-columns:
          "device_id":
            json-key: "device.device_id"
            value:
              type: "int"
              default: "0"
              required: true
          "record":
            json-key: "$"
            value:
              type: "jsonb"
              required: true