0.1.132
This commit is contained in:
		| @@ -1,7 +1,7 @@ | |||||||
| [metadata] | [metadata] | ||||||
| # replace with your username: | # replace with your username: | ||||||
| name = guan | name = guan | ||||||
| version = 0.1.131 | version = 0.1.132 | ||||||
| author = guanjihuan | author = guanjihuan | ||||||
| author_email = guanjihuan@163.com | author_email = guanjihuan@163.com | ||||||
| description = An open source python package | description = An open source python package | ||||||
|   | |||||||
| @@ -1,6 +1,6 @@ | |||||||
| Metadata-Version: 2.1 | Metadata-Version: 2.1 | ||||||
| Name: guan | Name: guan | ||||||
| Version: 0.1.131 | Version: 0.1.132 | ||||||
| Summary: An open source python package | Summary: An open source python package | ||||||
| Home-page: https://py.guanjihuan.com | Home-page: https://py.guanjihuan.com | ||||||
| Author: guanjihuan | Author: guanjihuan | ||||||
|   | |||||||
| @@ -1,12 +1,17 @@ | |||||||
| # Module: data_processing | # Module: data_processing | ||||||
|  |  | ||||||
| # AI模型对话(输入长度不能太长,且回答速度有一定限制) | # AI模型对话 | ||||||
| def chat(prompt='你好', stream=1, model=1, top_p=0.8, temperature=0.85): | def chat(prompt='你好', stream=1, model=1, top_p=0.8, temperature=0.85): | ||||||
|     import socket |     import socket | ||||||
|     import json |     import json | ||||||
|  |     import time | ||||||
|  |     import guan | ||||||
|     with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as client_socket: |     with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as client_socket: | ||||||
|         client_socket.settimeout(30) |         client_socket.settimeout(30) | ||||||
|         client_socket.connect(('socket.guanjihuan.com', 12345)) |         client_socket.connect(('socket.guanjihuan.com', 12345)) | ||||||
|  |         split_text_list = guan.split_text(prompt, wrap_width=100) | ||||||
|  |         message_times = len(split_text_list) | ||||||
|  |         if message_times == 1 or message_times == 0: | ||||||
|             message = { |             message = { | ||||||
|                 'server': "chat.guanjihuan.com", |                 'server': "chat.guanjihuan.com", | ||||||
|                 'prompt': prompt, |                 'prompt': prompt, | ||||||
| @@ -16,6 +21,23 @@ def chat(prompt='你好', stream=1, model=1, top_p=0.8, temperature=0.85): | |||||||
|             } |             } | ||||||
|             send_message = json.dumps(message) |             send_message = json.dumps(message) | ||||||
|             client_socket.send(send_message.encode('utf-8')) |             client_socket.send(send_message.encode('utf-8')) | ||||||
|  |         else: | ||||||
|  |             end_message = 0 | ||||||
|  |             for i0 in range(message_times): | ||||||
|  |                 if i0 == message_times-1: | ||||||
|  |                     end_message = 1 | ||||||
|  |                 prompt_0 = split_text_list[i0] | ||||||
|  |                 message = { | ||||||
|  |                     'server': "chat.guanjihuan.com", | ||||||
|  |                     'prompt': prompt_0, | ||||||
|  |                     'model': model, | ||||||
|  |                     'top_p': top_p, | ||||||
|  |                     'temperature': temperature, | ||||||
|  |                     'end_message': end_message, | ||||||
|  |                 } | ||||||
|  |                 send_message = json.dumps(message) | ||||||
|  |                 client_socket.send(send_message.encode('utf-8')) | ||||||
|  |                 time.sleep(0.15) | ||||||
|         if stream == 1: |         if stream == 1: | ||||||
|             print('\n--- Begin Stream Message ---\n') |             print('\n--- Begin Stream Message ---\n') | ||||||
|         response = '' |         response = '' | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user