selenium+pyquery爬取淘宝

发布时间:2019-03-12 23:11:42编辑:auto阅读(2189)

    import re
    from selenium import webdriver
    from selenium.webdriver.common.by import By
    from selenium.webdriver.support.ui import WebDriverWait
    from selenium.webdriver.support import expected_conditions as EC
    from selenium.common.exceptions import TimeoutException 
    from pyquery import PyQuery as pq
    
    option=webdriver.ChromeOptions()
    option.add_argument('--headless')
    browser = webdriver.Chrome(chrome_options=option)
    
    wait=WebDriverWait(browser, 10)
    
    def search():
        try:
            browser.get("https://www.taobao.com")
      
            input=wait.until(
                EC.presence_of_element_located((By.CSS_SELECTOR, '#q'))
            )
            submit = wait.until(
                    EC.element_to_be_clickable((By.CSS_SELECTOR,'#J_TSearchForm > div.search-button > button')))
            input.send_keys('美食')
            submit.click()
            total=wait.until(EC.presence_of_element_located((By.CSS_SELECTOR,'#mainsrp-pager > div > div > div > div.total')))
            get_products()
            return total.text
        except TimeoutException:
            return search()
    
    def get_products():
        wait.until(EC.presence_of_element_located((By.CSS_SELECTOR,'#mainsrp-itemlist .items .item')))
        html = browser.page_source
        doc = pq(html)
        items = doc('#mainsrp-itemlist .items .item').items() #参见官网http://pyquery.readthedocs.io/en/latest/api.html
        for item in items:
            #以下使用pyquery选择器选择元素
            product = {
                'image':item.find('.pic .img').attr('src'),
                'price':item.find('.price').text().replace('\n',''),
                'deal':item.find('.deal-cnt').text()[:-3],
                'title':item.find('.title').text().replace('\n',''),
                'shop':item.find('.shop').text(),
                'location':item.find('.location').text(),
            }
            print(product)
    
    def main():
        total=search()
        total=int(re.compile('(\d+)').search(total).group(1))
        for i in range(2,total+1):
            next_page(i)
            
        browser.close()
    
    def next_page(page_number):
        try:
            input=wait.until(
                    EC.presence_of_element_located((By.CSS_SELECTOR, '#mainsrp-pager > div > div > div > div.form > input'))
                )
            submit = wait.until(
                    EC.element_to_be_clickable((By.CSS_SELECTOR,'#mainsrp-pager > div > div > div > div.form > span.btn.J_Submit')))
            input.clear()
            input.send_keys(page_number)
            submit.click()
            wait.until(EC.text_to_be_present_in_element((By.CSS_SELECTOR,'#mainsrp-pager > div > div > div > ul > li.item.active > span'),str(page_number)))
            get_products()
        except TimeoutException:
             next_page(page_number)   
    
    if __name__=='__main__':
        main()
    
    
        

     

关键字