Ru-hulu/EVO_Train
Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|
ย | ย | |||
ย | ย | |||
ย | ย | |||
ย | ย | |||
ย | ย | |||
ย | ย | |||
ย | ย | |||
ย | ย | |||
Repository files navigation
start๏ผ
python3 server_tcp/server_connection.py --host 0.0.0.0 --port 9000 --workers 4
structure๏ผ
โโโโโโโโโโโโโโโโโโโโโโ
Client
roboclaw ่ฎญ็ปไธญๅฟ-ๅจ็บฟ่ฎญ็ป
JSON request + \n
โโโโโโโโโโโฌโโโโโโโโโโโ
โ TCP ้ฟ่ฟๆฅ
โผ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ server_connection.py
โ reactor-actor ๆจกๅๅๅบ็จๆท้พๆฅ/่ฏทๆฑ
โ 1. ็ๅฌ็ซฏๅฃ 9000
โ 2. accept ๅฎขๆท็ซฏ่ฟๆฅ
โ 3. selector/epoll ็ฎก็ socket ไบไปถ๏ผๅปบ็ซ้พๆฅ / ๅๅบไปปๅก
โ 4. ็ปดๆค้ฟ่ฟๆฅ idle timeout
โ 5. ็ๆ TaskEvent๏ผไบค็ป็บฟ็จๆฑ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ submit_lite(event)
โผ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ thread_pool.py
โ ็บฟ็จๆฑ ๏ผๅฏๅจ 4/8 ไธช worker ็บฟ็จ
โ 1. ็ปดๆคไปปๅก้ๅ๏ผ็บฟ็จๆถ่ดน train_task_queue
โ 2. worker ๆถ่ดน TaskEvent
โ 3. ่ฐ็จไธๅกๅฝๆฐ handle_request ๅค็่ฏทๆฑ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโฌโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ ๆฐๆฎๅบ็ฎก็็จๆทไปปๅกไฟกๆฏ sql_xxx()
โผ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
โ sql_pack.py
โ 1. ้ฟ้ไบ RDS MySQL ๅๅงๅ
โ 2. sql_get_user_all_task ่ทๅไธไธช็จๆท็ๆๆไปปๅก
โ 3. sql_add_user_task ไธบไธไธช็จๆทๆทปๅ ไปปๅก
โ 4. sql_delete_user_task ๅ ้คไธไธช็จๆท็ๆไธชไปปๅก
โ 5. ้่ฟ EVO_TRAIN_DATABASE_URL ๆ DATABASE_URL ่ฟๆฅๆฐๆฎๅบ
โโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโโ
database๏ผ
pip install PyMySQL
export EVO_TRAIN_DATABASE_URL='mysql+pymysql://user:password@rm-xxxx.mysql.rds.aliyuncs.com:3306/evo_train?charset=utf8mb4'
# ๅ
ผๅฎน evo-data_backend ็้
็ฝฎๅฝๅ๏ผไนๅฏไปฅไฝฟ็จ๏ผ
export DATABASE_URL='mysql+pymysql://user:password@rm-xxxx.mysql.rds.aliyuncs.com:3306/evo_train?charset=utf8mb4'