add new line

element_14_data_process.py

@@ -117,5 +117,9 @@ if __name__ == '__main__':
     # 解析并推送
     # 解析并推送
     HandleTxT().parse(unzip_name)
     HandleTxT().parse(unzip_name)
     end = time.time()
     end = time.time()
+    producer.close()
+    # 清理文件
+    os.remove(file_name)
+    os.remove(unzip_name)
     logger.info("handle file: eCat_element14_CN_BI.txt total spend time: " + str(end - start))
     logger.info("handle file: eCat_element14_CN_BI.txt total spend time: " + str(end - start))