dssm train

recommend-model-produce/src/main/python/models/dssm/milvus_import.py

@@ -56,7 +56,7 @@ def thread_task(name, file_list):
         output_file = f"/app/milvus-{file_name}.json"
         write_results(json.dumps({"rows":result}, indent=4), output_file)
 
-        oss_object_name="dyp/milvus"
+        oss_object_name=f"dyp/milvus/{file_name}.json"
         oss_client.put_object_from_file(oss_object_name, output_file)
 
         #compress.compress_file_tar(output_file, f"{output_file}.tar.gz")