singer_python_tap_schema_and_record_output_quickstart.py

1import singer
2
3# Define the schema for the data being synced
4schema = {
5    'properties': {
6        'id': {'type': 'integer'},
7        'name': {'type': 'string'},
8    },
9}
10
11def main():
12    # Write the schema to stdout
13    singer.write_schema('my_table', schema, 'id')
14    
15    # Write a record to stdout
16    singer.write_records('my_table', [
17        {'id': 1, 'name': 'Alice'},
18        {'id': 2, 'name': 'Bob'},
19    ])
20
21if __name__ == '__main__':
22    main()