flow-record 0.4.10

library to create records to be used by the rdump cli utility
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
47
48
49

import sys
from flow.record import RecordDescriptor, RecordStreamWriter

TestRecord1 = RecordDescriptor(
    "test/csv_test1",
    [
        ("string", "field11"),
        ("string", "field12"),
        ("string", "field13"),
        ("dictlist", "field14")
    ]
)

TestRecord2 = RecordDescriptor(
    "test/csv_test2",
    [
        ("string", "field21"),
        ("string", "field22"),
        ("string", "field23"),
    ]
)

rec1 = TestRecord1(
    field11 = "AB",
    field12 = "CD",
    field13 = "EF",
    field14 = {
        "Name": "George",
        "Surname": "Washington"
    }
)

rec2 = TestRecord2(
    field21 = "PQ",
    field22 = "RS",
    field23 = "TU",
)

rec3 = TestRecord1(
    field11 = "K\\L",
    field12 = "M\\\\N",
    field13 = "O\\\"'PQR",
)

record_writer = RecordStreamWriter(sys.stdout.buffer)

record_writer.write(rec1)
record_writer.write(rec2)
record_writer.write(rec3)