久久国产成人av_抖音国产毛片_a片网站免费观看_A片无码播放手机在线观看,色五月在线观看,亚洲精品m在线观看,女人自慰的免费网址,悠悠在线观看精品视频,一级日本片免费的,亚洲精品久,国产精品成人久久久久久久

分享

Puppeteer使用示例

 黃金屋1 2019-12-24

PhantomJS曾經(jīng)是無頭瀏覽器里的王者,,測試,、爬蟲等都在使用,,隨著GoogleChrome Headless的出現(xiàn),,PhantomJS的作者已經(jīng)明確表示不在更新,,而GoogleChrome Headless將會是未來爬蟲的趨勢,,而測試將依然會使用Webdriver那套方案,GoogleChrome Headless可以利用WebDriver調(diào)用,,也可以使用其集成的API——Puppeteer(操縱木偶的人),,他的功能和他的名字一樣強(qiáng)大,可以隨意操控Chrome或Chromeium,,缺點(diǎn)就是只有node的API,來看看他的圖標(biāo):


Puppeteer是基于DevTools協(xié)議來控制headless Chrome的Node庫,,依賴6.4以上版本的node,本人是在接觸這個軟件時才開始學(xué)習(xí)node,,依然感覺到它的異步async/await超級強(qiáng)大,,在Puppeteer中也大量使用異步來完成任務(wù)。

Puppeteer的安裝可以使用node的包管理工具npm來安裝:

npm i puppeteer

這里安裝時會自動安裝Chromeium,,如果不需要則可以通過配置npm跳過下載,,做為一名爬蟲工程師我不會去討論測試相關(guān)的使用,,接下來看看如何使用,和WebDriver類似,,首先需要實例化brower,,代碼如下:

  1. const puppeteer = require('puppeteer');
  2. (async () => {
  3. const browser = await puppeteer.launch();
  4. const page = await browser.newPage();
  5. await page.goto('http://www.baidu.com');
  6. await browser.close();
  7. })();

這段代碼執(zhí)行結(jié)束時,你可能什么也沒有感覺到,,因為它在后臺啟動了一個Chromeium進(jìn)程,,打開了百度首頁,接著就關(guān)閉了,,當(dāng)然我們可以在前臺打開Chromeium,,這里就需要配置一下,所配置參數(shù)只需傳入launch()即可,,常用參數(shù)如下:

    headless:  是否打開瀏覽器,,默認(rèn)為true

    ignoreHTTPSErrors: 是否忽略https錯誤,默認(rèn)為true

    executablePath:  配置要調(diào)用瀏覽器的可執(zhí)行路徑,,默認(rèn)是同Puppeteer一起安裝的Chromeium

    slowMo:指定的毫秒延緩Puppeteer的操作

    args:設(shè)置瀏覽器的相關(guān)參數(shù),,比如是否啟動沙箱模式“--no-sandbox”,是否更換代理“--proxy-server”,,具體參數(shù)請點(diǎn)此查看

使用示例如下:

const browser = await puppeteer.launch({headless:false, args: ["--no-sandbox",]})  //打開瀏覽器

打開新的窗口:

 const page = await browser.newPage();

設(shè)置窗口大小

  1. await page.setViewport({
  2. width: 1920,
  3. height: 1080
  4. })

過濾不需要的請求:

  1. await page.setRequestInterception(true);
  2. page.on('request', interceptedRequest => {
  3. if (interceptedRequest.url().endsWith('.png') || interceptedRequest.url().endsWith('.jpg'))
  4. interceptedRequest.abort();
  5. else
  6. interceptedRequest.continue();
  7. });

為瀏覽器設(shè)置userAgent:

 await page.setUserAgent("Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.36 Edge/16.16299")

設(shè)置cookie,,

  1. const data = {
  2. name: "smidB2",
  3. domain: ".csdn.net",
  4. value: "201806051502283cf43902aa8991a248f9c605204f92530032f23ef22c16270"
  5. }
  6. await page.setCookie(data)

示例中只是演示,真實的cookie是一個列表形式的,,需要循環(huán)添加才可以

  1. for(let data of cookies){
  2. await page.setCookie(data)
  3. }

請求url:

  1. const url = "http://www.baidu.com"
  2. await page.goto(url, { waitUntil: "networkidle2" });

設(shè)置頁面等待時間:

await page.waitFor(1000); // 單位是毫秒

等待頁面某個元素加載完成

await page.waitForSelector("input[class='usrname']")

點(diǎn)擊某個元素

await page.click("input[class='submit']")

利用page.evaluate()函數(shù)拖動鼠標(biāo)至頁面底部,原理就是在頁面注入js代碼,。

  1. let scrollEnable = false;
  2. let scrollStep = 500; //每次滾動的步長
  3. while (scrollEnable) {
  4. scrollEnable = await page.evaluate((scrollStep) => {
  5. let scrollTop = document.scrollingElement.scrollTop;
  6. document.scrollingElement.scrollTop = scrollTop + scrollStep;
  7. return document.body.clientHeight > scrollTop + 1080 ? true : false
  8. }, scrollStep);
  9. await page.waitFor(600)
  10. }

獲取html信息

  1. const frame = await page.mainFrame()
  2. const bodyHandle = await frame.$('html');
  3. const html = await frame.evaluate(body => body.innerHTML, bodyHandle);
  4. await bodyHandle.dispose(); //銷毀
  5. console.log(html)

這是爬蟲能用到的大致操作,,以下是爬取豆瓣熱門電影的基本信息和評分的代碼,寫這個程序時對node也是一知半解,,如有不對,,歡迎留言

basePupp.js

  1. const puppeteer = require("puppeteer")
  2. class BasePuppeteer{
  3. puppConfig(){
  4. const config = {
  5. headless: false
  6. }
  7. return config
  8. }
  9. async openBrower(setting){
  10. const browser = puppeteer.launch(setting)
  11. return browser
  12. }
  13. async openPage(browser){
  14. const page = await browser.newPage()
  15. return page
  16. }
  17. async closeBrower(browser){
  18. await browser.close()
  19. }
  20. async closePage(page){
  21. await page.close()
  22. }
  23. }
  24. const pupp = new BasePuppeteer()
  25. module.exports = pupp

douban.js

  1. const pupp = require("./basePupp.js")
  2. const cheerio = require("cheerio")
  3. const mongo = require("mongodb")
  4. const assert = require("assert")
  5. const MongoClient = mongo.MongoClient
  6. const Urls = "mongodb://10.4.251.129:27017/douban"
  7. MongoClient.connect(Urls, function (err, db) {
  8. if (err) throw err;
  9. console.log('數(shù)據(jù)庫已創(chuàng)建');
  10. var dbase = db.db("runoob");
  11. dbase.createCollection('detail', function (err, res) {
  12. if (err) throw err;
  13. console.log("創(chuàng)建集合!");
  14. db.close();
  15. });
  16. });
  17. async function getList(){
  18. const brower = await pupp.openBrower()
  19. const page = await pupp.openPage( brower)
  20. const url = "https://movie.douban.com/explore#!type=movie&tag=%E7%83%AD%E9%97%A8&sort=recommend&page_limit=20&page_start=0"
  21. await page.goto(url);
  22. while(true){ // 循環(huán)點(diǎn)擊, 直到獲取不到該元素
  23. try{
  24. await page.waitFor(1000);
  25. await page.waitForSelector('a[class=more]'); // 等待元素加載完成,超時時間30000ms
  26. await page.click("a[class=more]")
  27. // break
  28. }catch(err){
  29. console.log(err)
  30. console.log("stop click !!!")
  31. break
  32. }
  33. }
  34. await page.waitFor(1000); // 等待頁面一秒
  35. const links = await page.evaluate(() => { // 獲取電影詳情url
  36. let movies = [...document.querySelectorAll('.list a[class=item]')];
  37. return movies.map((movie) =>{
  38. return {
  39. href: movie.href.trim(),
  40. }
  41. });
  42. });
  43. console.log(links.length)
  44. for (var i = 0; i < links.length; i++) {
  45. const a = links[i];
  46. await page.waitFor(2000);
  47. await getDetail(brower, a.href)
  48. // break
  49. }
  50. await pupp.closePage(page)
  51. await pupp.closeBrower(brower)
  52. }
  53. async function getDetail(brower, url){
  54. const page = await pupp.openPage(brower)
  55. await page.goto(url);
  56. await page.waitFor(1000);
  57. try{
  58. await page.click(".more-actor", {delay: 20})
  59. }catch(err){
  60. console.log(err)
  61. }
  62. const frame = await page.mainFrame()
  63. const bodyHandle = await frame.$('html');
  64. const html = await frame.evaluate(body => body.innerHTML, bodyHandle);
  65. await bodyHandle.dispose(); // 銷毀
  66. const $ = cheerio.load(html)
  67. const title = $("h1 span").text().trim()
  68. const rating_num = $(".rating_num").text().trim()
  69. const data = {}
  70. data["title"] = title
  71. data["rating_num"] = rating_num
  72. let info = $("#info").text()
  73. const keyword = ["director", "screenplay", "lead", "type", "website", "location", "language", "playdate", "playtime", "byname", "imdb"]
  74. if (info.indexOf("www.") > 0){
  75. info = info.replace(/https:\/\/|http:\/\//g, "").replace(/\t/g," ").replace(/\r/g, " ").split(":")
  76. for(var i = 1; i < info.length; i++){
  77. data[keyword[i-1]] = info[i].split(/\n/g)[0].replace(/ \/ /g, ",").trim()
  78. }
  79. }else{
  80. info = info.replace(/\t/g," ").replace(/\r/g, " ").split(":")
  81. keyword.splice(4,1)
  82. for(var i = 1; i < info.length-1; i++){
  83. data[keyword[i-1]] = info[i].split(/\n/g)[0].replace(/ \/ /g, ",").trim()
  84. }
  85. data["website"] = ""
  86. }
  87. // console.log(data)
  88. MongoClient.connect(Urls,function(err,db){ //獲取連接
  89. assert.equal(null,err); //使用斷言模塊代替以前的 if判斷
  90. var dbo = db.db("douban");
  91. dbo.collection("detail").insert(data, function(err,result){ //連接到數(shù)據(jù)庫上面,,并使用參數(shù)傳入集合
  92. assert.equal(null,err);
  93. console.log(result);
  94. db.close();
  95. });
  96. });
  97. await pupp.closePage(page)
  98. }
  99. getList()

以上的代碼完成了對豆瓣熱門電影的全部抓取,,有以下幾個步驟:

1, 循環(huán)點(diǎn)擊加載更多,,直到?jīng)]有此元素可操作而拋出異常

2,,加載完全部熱門電影列表時解析出每個電影詳情頁的url并逐一請求

3, 解析詳情頁的所需數(shù)據(jù),,

4,,對所抓取數(shù)據(jù)進(jìn)行入庫,這里使用MongoDB

入庫后的數(shù)據(jù)如下所示:


對以上的瀏覽器實例化做了優(yōu)化,,寫成了單例模式

config.js

  1. module.exports = {
  2. browserOptions:{
  3. headless: false,
  4. // args: ['--no-sandbox', '--proxy-server=http://proxy:[email protected]:8995'],
  5. args: ['--no-sandbox'],
  6. }
  7. };

brower.js

  1. const puppeteer = require("puppeteer");
  2. const config = require('./config');//
  3. const deasync = require('deasync');
  4. const BROWSER_KEY = Symbol.for('browser');
  5. const BROWSER_STATUS_KEY = Symbol.for('browser_status');
  6. launch(config.browserOptions)
  7. wait4Lunch();
  8. /**
  9. * 啟動并獲取瀏覽器實例
  10. * @param {*} options
  11. * param options is puppeteer.launch function's options
  12. */
  13. function launch(options = {}) {
  14. if (!global[BROWSER_STATUS_KEY]) {
  15. global[BROWSER_STATUS_KEY] = 'lunching';
  16. puppeteer.launch(options)
  17. .then((browser) => {
  18. global[BROWSER_KEY] = browser;
  19. global[BROWSER_STATUS_KEY] = 'lunched';
  20. })
  21. .catch((err) => {
  22. global[BROWSER_STATUS_KEY] = 'error';
  23. throw err;
  24. });
  25. }
  26. }
  27. function wait4Lunch(){
  28. while (!global[BROWSER_KEY] && global[BROWSER_STATUS_KEY] == 'lunching') {
  29. // wait for lunch
  30. deasync.runLoopOnce();
  31. }
  32. }
  33. module.exports = global[BROWSER_KEY];

    本站是提供個人知識管理的網(wǎng)絡(luò)存儲空間,,所有內(nèi)容均由用戶發(fā)布,,不代表本站觀點(diǎn)。請注意甄別內(nèi)容中的聯(lián)系方式,、誘導(dǎo)購買等信息,,謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,,請點(diǎn)擊一鍵舉報,。
    轉(zhuǎn)藏 分享 獻(xiàn)花(0

    0條評論

    發(fā)表

    請遵守用戶 評論公約

    類似文章 更多