Google Cloud IoT sendCommandToDevice из облачных функций, показывающих, что Сервис недоступен

Question

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

Package.JSON "зависимости": { "firebase-admin": "~ 6.0.0", "firebase-functions": "^ 2.0.3", "googleapis": "34.0.0" }

const parentName = `projects/${projectId}/locations/${cloudRegion}`;
const registryName = `${parentName}/registries/${reqData.registryId}`;
const binaryData = Buffer.from(JSON.stringify(reqData.message)).toString('base64');
const request = {
    name: `${registryName}/devices/${reqData.deviceId}`,
    binaryData: binaryData
};

google.auth.getClient().then((authClient) => {
    const discoveryUrl =
        `${DISCOVERY_API}?version=${API_VERSION}`;
    if (authClient.createScopedRequired && authClient.createScopedRequired()) {
      // Scopes can be specified either as an array or as a single,
      // space-delimited string.
      authClient = authClient.createScoped([
        'https://www.googleapis.com/auth/cloud-platform'
      ]);
    }

    google.options({
      auth: authClient
    });

    google.discoverAPI(discoveryUrl).then((client, err) => {
      if (err) {
        console.log('Error during API discovery', err);
        return undefined;
      }
      client.projects.locations.registries.devices.sendCommandToDevice(request,
        (err, data) => {
          if (err) {
            console.log('Could not send command:', request);
            console.log('Message: ', err);
          } else {
            console.log('Success :', data.statusText);
          }
        });
    });
  });

Журналы: {Ошибка: сервис в данный момент недоступен. в createError (/user_code/node_modules/googleapis/node_modules/axios/lib/core/createError.js:16:15) при настройке (/user_code/node_modules/googleapis/node_modules/axios/lib/core/settle.js:18: 12) в Unzip.handleStreamEnd (/user_code/node_modules/googleapis/node_modules/axios/lib/adapters/http.js:201:11) в emitNone (events.js: 91: 20) в Unzip.emit (events.js: 185: 7) в endReadableNT (_stream_readable.js: 974: 12) в _combinedTickCallback (внутренний / process / next_tick.js: 80: 11) в process._tickDomainCallback (внутренний / process / next_tick.js: 128: 9)

Answer 1

Проблема в том, что subfolder ДОЛЖЕН быть указан, а ДОЛЖЕН не быть пустой строкой.

Поскольку я использовал это в функции Firebase, я просто использую подпапку firebase для всех отправляемых команд, которые не имеют определенной подпапки

const request = {
    name: `${registryName}/devices/${deviceId}`,
    binaryData: Buffer.from(JSON.stringify(commandMessage)).toString("base64"),
    subfolder: 'firebase'
}

Вот функции deps:

  "dependencies": {
    "firebase-admin": "^6.4.0",
    "firebase-functions": "^2.1.0",
    "fs-extra": "^7.0.0",
    "googleapis": "^36.0.0",
  },

Это, вероятно, связано с

1. ошибка в библиотеке узлов
2. ошибка в конечной точке Google
3. Отсутствие тестирования со стороны Google

Кажется, что Google IoT еще очень молод и нуждается в большой работе

Answer 2

Я не слишком знаком с облачными функциями Firebase, но я не получил ошибку с помощью встроенного редактора облачных функций (https://console.cloud.google.com/functions).. Можете ли вы сказать мне, когда вы начали получать эту ошибку (и если вы все еще сталкиваетесь с этим)?

Для справки, здесь был код, который я использовал (в основном то, что вы имели, но с более явными определениями для projectId, cloudRegion.

const {google} = require('googleapis');

const API_VERSION = 'v1';
const DISCOVERY_API = 'https://cloudiot.googleapis.com/$discovery/rest';

exports.sendCommand = (req, res) => {
  let reqData = req.body;

  const projectId = reqData.projectId || process.env.GCLOUD_PROJECT;
  const cloudRegion = reqData.cloudRegion || process.env.GCLOUD_REGION;

  const parentName = `projects/${projectId}/locations/${cloudRegion}`;
  const registryName = `${parentName}/registries/${reqData.registryId}`;
  const binaryData = Buffer.from(JSON.stringify(reqData.message)).toString('base64');
  const request = {
      name: `${registryName}/devices/${reqData.deviceId}`,
      binaryData: binaryData
  };

  google.auth.getClient().then((authClient) => {
      const discoveryUrl =
          `${DISCOVERY_API}?version=${API_VERSION}`;
      if (authClient.createScopedRequired && authClient.createScopedRequired()) {
        // Scopes can be specified either as an array or as a single,
        // space-delimited string.
        authClient = authClient.createScoped([
          'https://www.googleapis.com/auth/cloud-platform'
        ]);
      }

      google.options({
        auth: authClient
      });

      google.discoverAPI(discoveryUrl).then((client, err) => {
        if (err) {
          console.log('Error during API discovery', err);
          return undefined;
        }
        client.projects.locations.registries.devices.sendCommandToDevice(request,
          (err, data) => {
            if (err) {
              console.log('Could not send command:', request);
              console.log('Message: ', err);
            } else {
              console.log('Success :', data.statusText);
            }
          });
      });
    });
  res.status(200).send(reqData.message);
};