Meltano tap emulator

generate_messages.py

import json
import sys

size = int(sys.argv[1])

stream_name = "speed_test"

schema_message = {
    "type": "SCHEMA",
    "stream": stream_name,
    "schema": {
        "properties": {
            "id": {
                "type": "integer"
            }
        }
    },
    "key_properties": [
        "id"
    ]
}

print(json.dumps(schema_message))

for i in range(size):
    print(json.dumps({"type": "RECORD", "stream": stream_name, "record": {"id": i}}))