2

在 NodeJS v10.xx 环境中，当尝试从一些 HTML 代码创建 PDF 页面时，每次尝试使用它（setCacheEnabled、setRequestInterception 等）时都会遇到关闭页面问题：

async (page, data) => {
  try {
    const {options, urlOrHtml} = data;
    const finalOptions = { ...config.puppeteerOptions, ...options };

    // Set caching flag (if provided)
    const cache = finalOptions.cache;
    if (cache != undefined) {
      delete finalOptions.cache;
      await page.setCacheEnabled(cache); //THIS LINE IS CAUSING THE PAGE TO BE CLOSED
    }

    // Setup timeout option (if provided)
    let requestOptions = {};
    const timeout = finalOptions.timeout;
    if (timeout != undefined) {
      delete finalOptions.timeout;
      requestOptions.timeout = timeout;
    }

    requestOptions.waitUntil = 'networkidle0';
    if (urlOrHtml.match(/^http/i)) {
      await page.setRequestInterception(true); //THIS LINE IS CAUSING ERROR DUE TO THE PAGE BEING ALREADY CLOSED
      page.once('request', request => {

        if(finalOptions.method === "POST" && finalOptions.payload !== undefined) {
          request.continue({method: 'POST', postData: JSON.stringify(finalOptions.payload)});
        }
      });

      // Request is for a URL, so request it
      await page.goto(urlOrHtml, requestOptions);
    }

    return await page.pdf(finalOptions);
  } catch (err) {
    logger.info(err);
  }
};

我在某处读到这个问题可能是由于缺少一些等待引起的，但这看起来不像我的情况。

我没有直接使用 puppeteer，但是这个库在它之上创建了一个集群并处理进程：

https://github.com/thomasdondorf/puppeteer-cluster

4

2 回答 2

3

您已经给出了解决方案，但由于这是图书馆的一个常见问题（我是作者），我想提供更多见解。

任务功能如何工作

当作业排队并准备好执行时，puppeteer-cluster将创建一个页面并cluster.task使用创建的page对象和排队的数据调用任务函数（给定）。然后集群等待直到 Promise 完成（完成或拒绝），然后关闭页面并执行队列中的下一个作业。

由于 async-function 隐式创建 Promise，这意味着一旦给cluster.task函数的 async-function 完成，页面就会关闭。确定该页面将来是否可以使用并不会有什么神奇的事情发生。

等待异步事件

下面是一个有一个常见错误的代码示例。用户可能希望在关闭页面之前等待外部事件，如下面的（不工作）示例所示：

非工作（！）代码示例：

await cluster.task(async ({ page, data }) => {
    await page.goto('...');
    setTimeout(() => { // user is waiting for an asynchronous event
        await page.evaluate(/* ... */); // Will throw an error as the page is already closed
    }, 1000);
});

在这段代码中，页面在异步函数执行之前已经关闭。正确的方法是返回一个 Promise 。

工作代码示例：

await cluster.task(async ({ page, data }) => {
    await page.goto('...');

    // will wait until the Promise resolves
    await new Promise(resolve => {
        setTimeout(() => { // user is waiting for an asynchronous event
            try {
                await page.evalute(/* ... */);
                resolve();
            } catch (err) {
                // handle error
            }
        }, 1000);
    });
});

在此代码示例中，任务函数会一直等待，直到内部 promise 被解析，直到它解析函数。这将保持页面打开，直到异步函数调用resolve。此外，代码使用try..catch块，因为库无法捕获异步代码块内引发的事件。

于 2019-05-07T17:18:04.257 回答
1

我知道了。

我确实忘记了对我发布的函数的调用的等待。

该调用位于我用于创建集群实例的另一个文件中：

async function createCluster() {
  //We will protect our app with a Cluster that handles all the processes running in our headless browser
  const cluster = await Cluster.launch({
    concurrency: Cluster[config.cluster.concurrencyModel],
    maxConcurrency: config.cluster.maxConcurrency
  });

  // Event handler to be called in case of problems
  cluster.on('taskerror', (err, data) => {
    console.log(`Error on cluster task... ${data}: ${err.message}`);
  });

  // Incoming task for the cluster to handle
  await cluster.task(async ({ page, data }) => {
    main.postController(page, data); // <-- I WAS MISSING A return await HERE
  });

  return cluster;
}
于 2019-05-07T09:13:45.523 回答