Python在同一行上进行多次迭代

如何解决Python在同一行上进行多次迭代

我想遍历sqlite表中的行，并且代码正在工作，但是它在移至下一行之前运行了4次该功能。

def get_ship_tm_window():
    # connect to database
    conn = sqlite3.connect('PSC.sdb')
    # create cursor
    c = conn.cursor()
    f = conn.cursor()
    c.execute("DELETE FROM 'inspections tm'")
    conn.commit()
    with requests.Session() as s:
        for row in c.execute("SELECT * FROM ships ORDER BY ISM"):
            print(row)
            ship_imo = row[1]
            print(ship_imo)
            get_tm_windows_access(s,ship_imo)
            f.execute(
                "INSERT INTO 'inspections tm' VALUES(:name,:imoship,:lastinsp,:ship_risk,:date_pii,:date_pi,:prio)",{
                    'name': row[0],'imoship': row[1],'lastinsp': '','ship_risk': get_tm_windows_access(s,ship_imo)[0],'date_pii': get_tm_windows_access(s,ship_imo)[2],'date_pi': get_tm_windows_access(s,ship_imo)[3],'prio': get_tm_windows_access(s,ship_imo)[1]
                })
            conn.commit()
    conn.close()


get_ship_tm_window()

结果是：

('HANNA OLDENDORFF',9731614,'Anglo-Eastern (Germany) GmbH',5365996,'High','High') # prints row OK
9731614 #prints imo OK
7B9E9C8F-EAF8-46FA-A09E-6B852A5C7F4C #1ST TIME
High Risk Ship #1ST TIME
Priority I #1ST TIME
05/09/2019 #1ST TIME
05/11/2019 #1ST TIME
7B9E9C8F-EAF8-46FA-A09E-6B852A5C7F4C #2nd time
High Risk Ship #2nd time
Priority I #2nd time
05/09/2019 #2nd time
05/11/2019 #2nd time
7B9E9C8F-EAF8-46FA-A09E-6B852A5C7F4C #3RD TIME
High Risk Ship #3RD TIME
Priority I #3RD TIME
05/09/2019 #3RD TIME
05/11/2019 #3RD TIME
7B9E9C8F-EAF8-46FA-A09E-6B852A5C7F4C #4th time
High Risk Ship #4th time
Priority I #4th time
05/09/2019 #4th time
05/11/2019 #4th time

这里应该停止，但是我又得到了3次，直到它打印出新行。第4次之后，它将移至下一行。

已编辑。

def get_tm_windows_access(s,ship_imo):
    date_from = datetime.Now() - relativedelta(months=36)
    date_to = datetime.Now()

    header = {'User-Agent': 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML,like Gecko) Chrome/68.0.','Cookies': 'PHPSESSID=xxxxxxxxxxxxxxxxxxxxxxxxxxxx'}
    s.headers.update(header)
    r = s.get('https://apcis.tmou.org/public/')
    str_number = re.findall("<span[^>]+(.*?)</span>",r.text)[0]
    numbers = re.findall('[0-9]+',str_number)
    captcha = int(numbers[0]) + int(numbers[1])
    payload = {'captcha': captcha}
    r = s.post('https://apcis.tmou.org/public/?action=login',data=payload)
    check_text = re.findall('<b>(.*?)</b>',r.text)[0]
    payload1 = {'Param': 0,'Value': ship_imo,'imo': ship_imo,'callsign': '','name': '','compimo': '','compname': '','From': date_from.strftime('%d.%m.%Y'),'Till': date_to.strftime('%d.%m.%Y'),'authority': 0,'flag': 0,'class': 0,'ro': 0,'type': 0,'result': 0,'insptype': -1,'sort1': 0,'sort2': 'DESC','sort3': 0,'sort4': 'DESC'
                }
    r = s.post('https://apcis.tmou.org/public/?action=getships',data=payload1)
    try:
        acces_code = re.findall('<input type="hidden" value="([^>]*)"/>',r.text)[0]
        print(acces_code)
        payload2 = {'HUID': acces_code}
        r = s.post('https://apcis.tmou.org/public/?action=getship',data=payload2)
        try:
            ship_risk = re.findall('<h2>(.*?),(.*?)</h2>',r.text)[0][0]
            ship_prio = re.findall('<h2>(.*?),r.text)[0][1]
            ship_window_raw = re.findall('<h2 class="winInsprange">Window inspection Range:\n\n(.*?)</h2>',r.text)[0]
            ship_window_numbers = re.findall('[0-9]+',ship_window_raw)
            pII = ship_window_numbers[0] + '/' + ship_window_numbers[1] + '/' + ship_window_numbers[2]
            pI = ship_window_numbers[3] + '/' + ship_window_numbers[4] + '/' + ship_window_numbers[5]
            return ship_risk,ship_prio,pII,pI
        except IndexError:
            ship_risk = re.findall('<h2>(.*?),r.text)[0][1]
            pII = ''
            pI = ''
            return ship_risk,pI
    except IndexError:
        return '','',''

这里有剩下的代码。 它运行4次对我来说很奇怪。

解决方法

通过将结果分配给命名变量，然后为该元组索引以获取查询参数，避免多次调用其他函数get_tm_windows_access()。当前，您没有将第一个调用分配给任何对象，因此它与显示的行一起显示，但返回的输出未保存在任何地方。只需将输出保存到变量即可。

def get_ship_tm_window():
    # connect to database
    conn = sqlite3.connect('PSC.sdb')

    # create cursor
    c = conn.cursor()
    f = conn.cursor()
    c.execute("DELETE FROM 'inspections tm'")
    conn.commit()

    with requests.Session() as s:
        for row in c.execute("SELECT * FROM ships ORDER BY ISM"):
            print(row)
            ship_imo = row[1]
            print(ship_imo)

            access_data = get_tm_windows_access(s,ship_imo)   # ADJUSTED LINE
            f.execute(
                "INSERT INTO 'inspections tm' VALUES(:name,:imoship,:lastinsp,:ship_risk,:date_pii,:date_pi,:prio)",{
                    'name': row[0],'imoship': row[1],'lastinsp': '','ship_risk': access_data[0],# ADJUSTED LINE
                    'date_pii': access_data[2],# ADJUSTED LINE
                    'date_pi': access_data[3],# ADJUSTED LINE
                    'prio': access_data[1]                     # ADJUSTED LINE
                })
            conn.commit()
    conn.close()