Search answers , lots of answers already about plugging in a custom response handler for the Rest Modular Input that will perform preprocessing actions such as splitting out events.
Add a custom handler to rest_ta/bin/responsehandlers.py
class TwitterStatusHandler:
def __init__(self,**args):
pass
def __call__(self, response_object,raw_response_output,response_type,req_args,endpoint):
if response_type == "json":
output = json.loads(raw_response_output)
for status in output["statuses"]:
print_xml_stream(json.dumps(status))
else:
print_xml_stream(raw_response_output)
Apply custom handler to your REST input
... View more