获取当前机器人的当前运行的流程任务编号

import pymysql
import socket
# 获取本机计算机名称
hostname = socket.gethostname()
# 获取本机ip
ip = socket.gethostbyname(hostname)
#print(ip)
ip_list = ['58.1.5.14','58.1.5.25','58.1.5.26','58.1.5.27','58.1.5.29','58.1.5.35']
# 设置任务编号
task_no = ""
if ip in ip_list:
    #连接数据库
    db = pymysql.connect(host='58.1.5.8', user='isa', password='123456', database='isa', port=13306, charset='utf8')
    #使用cursor()方法创建一个游标对象
    cursor = db.cursor()
    #使用execute()方法执行SQL语句
    sql = f"SELECT AGENT_NO,USER_NAME FROM T_CDA_AGENT WHERE AGENT_IP='{ip}'"
    cursor.execute(sql)
    #使用fetall()获取全部数据
    data = cursor.fetchall()
    # 设置数据库中T_RPA_JOB表中CURR_ROBOT_NO 值
    curr_robot_no = ""
    for i in data:
        if i:
            curr_robot_no = f"{i[1]}@{i[0]}"
    #打印获取到的数据
    print(curr_robot_no)
    if curr_robot_no:
        #使用cursor()方法创建一个游标对象
        cursor = db.cursor()
        #使用execute()方法执行SQL语句
        sql = f"SELECT JOB_NO FROM T_RPA_JOB WHERE CURR_ROBOT_NO='{curr_robot_no}' AND STATUS='running'"
        #print(sql)
        cursor.execute(sql)
        #使用fetall()获取全部数据
        data = cursor.fetchall()
        if data:
            for i in data:
                task_no = i[0]
        else:
            task_no = f"当前ip{ip}的机器人没有启动运行流程"
    else:
        task_no = f"当前ip{ip}的机器人不在机器人队列中"
    #print(task_no)
    #关闭游标和数据库的连接
    cursor.close()
    db.close()
else:
    task_no = f"当前ip{ip}不是机器人运行IP"
    #print(task_no)
return task_no