client.py 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. import requests, os
  2. def cls_process_openai(path, client_id, one_key, name_column, api_key="sk-iREtaVNjamaBArOTlc_2BfGFJVPiU-9EjSFMUspIPBT3BlbkFJxS0SMmKZD9L9UumPczee4VKawCwVeGBQAr9MgsWGkA",
  3. proxy=False, chunk_size=100):
  4. # 定义请求的数据
  5. data = {
  6. "path": path,
  7. "client_id": client_id,
  8. "one_key": one_key,
  9. "name_column": name_column,
  10. "api_key": api_key,
  11. "proxy": proxy,
  12. "chunk_size":chunk_size
  13. }
  14. # 发送 POST 请求
  15. response = requests.post("http://172.28.5.44:8070/classify_openai/", json=data)
  16. # 处理响应
  17. if response.status_code == 200:
  18. result = response.json()
  19. print("接口响应:", result)
  20. else:
  21. print(f"请求失败,状态码: {response.status_code}")
  22. print("错误信息:", response.text)
  23. def cls_process_bert(path, client_id, name_column):
  24. # 定义请求的数据
  25. data = {
  26. "path": path,
  27. "client_id": client_id,
  28. "name_column": name_column
  29. }
  30. # 发送 POST 请求
  31. response = requests.post("http://172.28.5.44:8070/classify_bert/", json=data)
  32. # 处理响应
  33. if response.status_code == 200:
  34. result = response.json()
  35. print("接口响应:", result)
  36. else:
  37. print(f"请求失败,状态码: {response.status_code}")
  38. print("错误信息:", response.text)
  39. def upload_process(file_path, client_id):
  40. # 表单数据
  41. data = {
  42. 'client_id': client_id
  43. }
  44. # 发送 POST 请求
  45. with open(file_path, 'rb') as file:
  46. name = os.path.basename(file_path)
  47. files = {
  48. 'file': (name, file, 'text/plain') # 'text/plain' 是文件类型,可以根据需要修改
  49. }
  50. response = requests.post("http://ip:port/uploadfile/", data=data, files=files)
  51. # 处理响应
  52. if response.status_code == 200:
  53. result = response.json()
  54. print("接口响应:", result)
  55. return result.get('file_path')
  56. else:
  57. print(f"请求失败,状态码: {response.status_code}")
  58. print("错误信息:", response.text)
  59. return None
  60. def both_process(path, client_id, one_key, name_column):
  61. file_path = upload_process(file_path=path, client_id=client_id)
  62. if file_path:
  63. cls_process_openai(path=file_path, client_id=client_id, one_key=one_key, name_column=name_column)
  64. if __name__ == "__main__":
  65. # both_process(path="E:/code/name_classify/data_before/人群分类-自建站2024.08.xlsx", client_id='wangdalin', one_key='网店单号', name_column='收货姓名')
  66. # upload_process(file_path="E:/code/name_classify/data_before/人群分类-自建站2024.08.xlsx", client_id='wangdalin')
  67. # cls_process_openai(path="./process/wangdalin\\人群分类-自建站2024.08.xlsx",client_id='wangdalin', one_key='网店单号', name_column='收货姓名')
  68. cls_process_bert(path="./process/wangdalin/人群分类-自建站2024.08.xlsx",client_id='wangdalin', name_column='收货姓名')