A GCFunction to write data from PubSub to Datastore.

gcf_datastore.js

const datastore = require('google-cloud').datastore;

const _PROJECT_ID = 'my-project';

var datastoreClient = datastore({
  projectId: _PROJECT_ID
});

exports.subscribe = function subscribe(event, callback) {
  const pubsubMessage = event.data;
  const deviceId = pubsubMessage.attributes.deviceId;
  const deviceRegistryId = pubsubMessage.attributes.deviceRegistryId;
  let data;
  
  try {
    data = JSON.parse(Buffer.from(pubsubMessage.data, 'base64').toString());
  } catch(e) {
    console.error(e);
    return callback(e);
  }
  
  const obj = {
    timestamp: data.timestamp,
    device_id: deviceId,
    key: data.key,
    value: data.value
  };
  
  datastoreClient.save({
    key: datastoreClient.key(deviceRegistryId),
    data: obj
  }, function(err) {
    if (err) {
      console.log('datastore err : ', err);
      callback(err);
    } else {
      console.log('Saved to datastore');
      callback();
    }
  });
};

Hi, sir, may I know how to give the values of the Kind in the streaming data to push into the datastore

package.json file how can I create for this