Интегрируйте кукловода в слушателя функции облака Google - PullRequest
Новая
       300

Интегрируйте кукловода в слушателя функции облака Google

0 голосов
/ 10 апреля 2019

Я запускаю облачные функции Google под узлом времени выполнения 8 с выделением 2g для слушателя.Слушатель: работает без кукловода;Кукольник: работает, когда используется внутри запроса get;

Но я хочу, чтобы кукловод работал внутри моего слушателя, что заставляет моего уже действующего слушателя выдавать ошибку.

Я прочитал много документов и ни одноговстроить кукловода в слушателя.

Редактировать: я также пытался изменить тип возвращаемого значения на допустимый формат, но безрезультатно.

Мой действительный слушатель 

exports.listen = functions.firestore
    .document('/request/{id}')
    .onWrite((change, context) => {
        // Grab the data from the original function trigger 
        const document = await change.after.data()['data'];

        // Dummy return of what will eventually be given
        return change.after.ref.set(
            {
                results: [
                    { title: 'New Title', Country: 'Lala Land' },
                    { title: 'New Job', Country: 'Asgardia' }
                ]
            },
            { merge: true }
        );
    });

Действительная функция кукловода 

const express = require('express');
const functions = require('firebase-functions');
const puppeteer = require('puppeteer');
const app = express();
// Runs before every route. Launches headless Chrome.
app.all('*', async (req, res, next) => {
  // Note: --no-sandbox is required in this env.
  // Could also launch chrome and reuse the instance
  // using puppeteer.connect()
  res.locals.browser = await puppeteer.launch({
    args: ['--no-sandbox']
  });
  next(); // pass control to next route.
});
// Handler to take screenshots of a URL.
app.get('/screenshot', async function screenshotHandler(req, res) {
  const url = req.query.url;
  if (!url) {
    return res.status(400).send(
      'Please provide a URL. Example: ?url=https://example.com');
  }
  const browser = res.locals.browser;
  try {
    const page = await browser.newPage();
    await page.goto(url, {waitUntil: 'networkidle2'});
    const buffer = await page.screenshot({fullPage: true});
    res.type('image/png').send(buffer);
  } catch (e) {
    res.status(500).send(e.toString());
  }
  await browser.close();
});

Недопустимый слушатель с кукловодом изменен на минимальные потребности 

exports.listen = functions.firestore
    .document('/request/{id}')
    .onWrite((change, context) => {
        const document = change.after.data()['data'];
        async function benchmark() {

            const browser = await puppeteer.launch({
                args: ['--no-sandbox']
            });
            const page = await browser.newPage();
            await page.goto('http://picocms.org/', {
                waitUntil: 'networkidle2'
            });
            const content = await page.content();
            return content;
        }

        return change.after.ref.set(
            {
                // results: [
                //  { title: 'New Title', Country: 'Lala Land' },
                //  { title: 'New Job', Country: 'Asgardia' }
                // ]
                results: benchmark()
            },
            { merge: true }
        );
    });

Ошибка, генерируемая в журналах 

Error: Value for argument "data" is not a valid Firestore document. Input is not a plain JavaScript object (found in field results).
    at Object.validateUserInput (/srv/node_modules/@google-cloud/firestore/build/src/serializer.js:312:15)
    at validateDocumentData (/srv/node_modules/@google-cloud/firestore/build/src/write-batch.js:622:26)
    at WriteBatch.set (/srv/node_modules/@google-cloud/firestore/build/src/write-batch.js:242:9)
    at DocumentReference.set (/srv/node_modules/@google-cloud/firestore/build/src/reference.js:337:27)
    at exports.listen.functions.firestore.document.onWrite (/srv/index.js:57:27)
    at cloudFunctionNewSignature (/srv/node_modules/firebase-functions/lib/cloud-functions.js:114:23)
    at /worker/worker.js:825:24
    at <anonymous>
    at process._tickDomainCallback (internal/process/next_tick.js:229:7)

Ответы [ 2 ]

0 голосов
/ 10 апреля 2019

Ваша benchmark() функция async и, таким образом, будет возвращать Promise при вызове.

Поэтому вы пытаетесь сохранить Обещание здесь: 

        return change.after.ref.set(
            {
                results: benchmark()     // This is a promise
            },
            { merge: true }
        );

Вместо этого вы хотите сохранить разрешенное значение из Обещания. Вы должны изменить свою функцию на async, а затем добавить await перед вашим benchmark() вызовом. Тогда ваши данные станут «простым объектом JavaScript», и их можно будет сериализовать и сохранить.

0 голосов
/ 10 апреля 2019

Они действительно должны сделать документы для этого использования, но я нашел свое собственное решение, я просто должен согласиться использовать кукловода в посте или получить запрос, поскольку у вас не будет доступа к параметрам (запрос, ответ).

Для тех, кто хочет использовать это по-своему, здесь есть минимальное жизнеспособное решение для построения.

Примечание: я обновил среду выполнения до Node 10 (бета) с выделенным 2G. 

const functions = require('firebase-functions');
const puppeteer = require('puppeteer');
const app = require('express')();
const { db } = require('./util/admin');

// Runs before every route. Launches headless Chrome.
app.all('*', async (req, res, next) => {
    // Note: --no-sandbox is required in this env.
    // Could also launch chrome and reuse the instance
    // using puppeteer.connect()
    res.locals.browser = await puppeteer.launch({
        args: ['--no-sandbox']
    });
    next(); // pass control to next route.
});

app.post('/create', async (req, res) => {
    const request = {
        data: req.body.data,
        created: new Date().toISOString()
    };
    const browser = res.locals.browser;
    const page = await browser.newPage();
    await page.goto('http://picocms.org/', {
        waitUntil: 'networkidle2'
    });
    const content = await page.content();
    request.data = JSON.stringify(content);
    await browser.close();
    db.collection('request')
        .add(request)
        .then(doc => {
            return res.json({
                message: `[success] ${doc.id} Generated`
            });
        })
        .catch(e => {
            res.status(500).json({
                error: `[failed] No Request Was Saved _> ${e}`
            });
        });
});

exports.api = functions.https.onRequest(app);
...