def __init__(self):
self.recv_msgs = []<EOL>self.save_after_num = int(<EOL>ev("<STR_LIT>",<EOL>"<STR_LIT:100>"))<EOL>self.stop_after_num = int(<EOL>ev("<STR_LIT>",<EOL>"<STR_LIT>"))<EOL>if self.save_after_num < <NUM_LIT:0>:<EOL><INDENT>self.save_after_num = <NUM_LIT:1><EOL><DEDENT>if self.stop_after_num < <NUM_LIT:0>:<EOL><INDENT>self.stop_after_num = None<EOL><DEDENT>self.stop_for_file = ev(<EOL>"<STR_LIT>",<EOL>"<STR_LIT>")<EOL>self.dataset_name = ev(<EOL>"<STR_LIT>",<EOL>"<STR_LIT>")<EOL>self.save_dir = ev(<EOL>"<STR_LIT>",<EOL>"<STR_LIT>")<EOL>self.save_to_file = ev(<EOL>"<STR_LIT>",<EOL>"<STR_LIT>".format(<EOL>self.save_dir,<EOL>self.dataset_name,<EOL>rnow("<STR_LIT>")))<EOL>self.archive_file = ev(<EOL>"<STR_LIT>",<EOL>"<STR_LIT>".format(<EOL>self.save_dir,<EOL>self.dataset_name,<EOL>rnow("<STR_LIT>")))<EOL>self.debug = bool(ev(<EOL>"<STR_LIT>",<EOL>"<STR_LIT:0>") == "<STR_LIT:1>")<EOL>self.df = None<EOL>self.last_df = None<EOL>self.eth_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.ip_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.ipvsix_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.icmp_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.arp_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.tcp_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.udp_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.dns_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.raw_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.pad_keys = {"<STR_LIT>": "<STR_LIT:id>"}<EOL>self.all_keys = {}<EOL>self.all_keys_list = []<EOL>self.all_eth = []<EOL>self.all_ip = []<EOL>self.all_ipvsix = []<EOL>self.all_icmp = []<EOL>self.all_arp = []<EOL>self.all_tcp = []<EOL>self.all_udp = []<EOL>self.all_dns = []<EOL>self.all_raw = []<EOL>self.all_pad = []<EOL>self.all_flat = []<EOL>self.all_rows = []<EOL>self.client = build_ai_client_from_env()<EOL>self.request_dict = {}<EOL>if ANTINEX_PUBLISH_ENABLED:<EOL><INDENT>if os.path.exists(ANTINEX_PUBLISH_REQUEST_FILE):<EOL><INDENT>with open(ANTINEX_PUBLISH_REQUEST_FILE, "<STR_LIT:r>") as f:<EOL><INDENT>self.request_dict = json.loads(f.read())<EOL><DEDENT><DEDENT><DEDENT>
__init__