brightec
Home Services Projects Blog About Contact

Trigger Firebase Cloud Functions

Brightec discuss Firebase Cloud Functions 1
How do you trigger Firebase Cloud Functions when a file gets uploaded? We recently needed to take regularly updated text files and read them into a database. Here’s how we used Firebase to do it.

Firebase Cloud Functions

Firebase Cloud Functions are a mechanism of running backend code (written in JavaScript) which can be triggered in various ways. In this instance, we wanted to trigger functions based on a new file, so opted to use them in combination with Firebase Cloud Storage. Whenever a file gets uploaded our code is triggered.

https://firebase.google.com/docs/functions/

Implementation

Here you can see that we are listening for a change in file storage. We check if it's a file intended for this cloud function. Then we read the file from storage and pull out the data. We then break it up by line and add it into our database.

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp(functions.config().firebase);
const path = require('path');
const gcs = require('@google-cloud/storage')();

exports.updateObj = functions.storage.object().onChange(event => {
 const file = event.data; // The Storage object.
 const fileBucket = file.bucket; // The Storage bucket that contains the file.
 const filePath = file.name; // File path in the bucket.
 const contentType = file.contentType; // File content type.
 const fileName = path.basename(filePath); // Get the file name.

 if (fileName != "Obj.txt") {
 return;
 }
 console.log("STARTED");

 const db = admin.database();
 const objRef = db.ref("obj");

 return gcs.bucket(fileBucket)
 .file(filePath)
 .download()
 .then(function(data) {
 if (data)
 return data.toString("utf-8");
 })
 .then(function(data) {
 if (data) {
 var dataLines = data.split("\n");
 for (var i = 0; i < dataLines.length; i++) {
 var objLine = dataLines[i];
 if (isEmpty(objLine)) {
 return;
 }
 var objLineFields = objLine.split("|");

 objRef.child(objLineFields[0]).child("title").set(objLineFields[1]);
 }
 }
 })
 .catch(function(e) {
 console.error(e);
 });
});

function isEmpty(str) {
 return (!str || 0 === str.length);
}

Timeout!

This solution hits issues with larger datasets. Firebase cloud functions only allows for up to 540 secs per function (default of 60 secs). As soon as we started using bigger datasets we started hitting those timeouts.

In an attempt to combat the issue we tried exploring running promises (a Javascript concept) in parallel. Although parallelism is possible, when trying to handle errors correctly and working within those timeouts, it appeared this was never going to work for large datasets. Firebase may be planning a change to this behaviour, but for the moment our advice would be only to use this solution for smaller datasets.

Queued tasks on App Engine for Firebase 1 Our Code
Queued tasks on App Engine for Firebase
We’ve recently been exploring Google App Engine with Firebase. Here’s how we queued tasks between them.

Looking for something else?

Search over 200 blog posts from our team

Want to hear more?

Subscribe to our monthly digest of blogs to stay in the loop and come with us on our journey to make things better!