target_hotglue_singer_data_stream_quickstart.py

1import sys
2import json
3from target_hotglue.target import TargetHotglue
4
5def main():
6    # Example configuration for the target
7    config = {
8        "api_key": "YOUR_HOTGLUE_API_KEY",
9        "env_id": "YOUR_HOTGLUE_ENV_ID",
10        "flow_id": "YOUR_HOTGLUE_FLOW_ID"
11    }
12
13    # Initialize the target with the config
14    target = TargetHotglue(config=config)
15
16    # Read from stdin (standard Singer behavior)
17    input_data = sys.stdin.read()
18    
19    # Process the data (messages are usually passed via stdin in a pipeline)
20    # This call typically handles the record/state/schema messages
21    target.listen()
22
23if __name__ == "__main__":
24    main()