add process_stream_item_query in src/collect-ent-dist-v2.py