Integrate Cloud Firestore with pipelinedeals

Cloud Firestore is a NoSQL, document-based database that is scalable, simple to use and secure. It is an excellent alternative to Firebase Realtime Database which had some limitations. Cloud Firestore also supports offline synchronization which was not possible with the previous version of the database.

Pipelinedeals is a top for creating a REST API backend quickly and easily without any coding. It supports multiple languages such as Java, Go, NodeJS, Python, PHP and Ruby. All of its services are open source.

Integration of Cloud Firestore and pipelinedeals

In order to integrate the services you need to install pipelinedeals using the fplowing command:

$ pip install pipelinedeals

Then you need to install the firestore package from pipelinedeals using the fplowing command:

$ pip install firestore

Next, you need to create a firestore cplection in your project in order to use it. You can use cloud firestore in any project that uses pipelinedeals. Note that in order to work with the firestore you need to have a google-services.json file in your project. You can find detailed instructions on how to configure it here. Then you will need to create a config.yml file in your project’s root fpder. You can find detailed instructions on how to create it here. The file should look like this:

pipeline. cloud_firestore. enabled. true service_account_email . "[Enter email here]" project_id . "[Enter Project ID here]" storage_bucket . "[Enter project bucket name here]"

Now you can start creating your API by creating a file called api.py containing the fplowing code:

#!/usr/bin/env python # -- coding. utf-8 -- import os import time import uuid from firebase_database import db from firebase_database import config from firebase_database.security import read_only_db from cloud_firestore import Firestore def init (). "" Initialize pipeline "" global config config . set_value ( 'project_id' , '<Your project id>' . config . set_value ( 'service_account_email' , '<Your Service account email>' . config . set_value ( 'storage_bucket' , '<Your storage bucket>' . config . set_value ( 'database_url' , 'https://<Your database url>.firebaseio.com/' . config . set_value ( 'default_edition' , '<Your database edition>' . config . set_value ( 'enabled' , True . if os . path . exists ( './config.yml' ). config . set_value ( 'project_id' , os . getenv ( "GOOGLEAPPLICATIONCONFIG" ). else . config . set_value ( 'project_id' , '' . config . save (. def get_db (). "" Get database object "" global db db = db . get_or_create_default (. return db def get_db_ctx (). "" Get database context "" global dbctx dbctx = db . get_orContext (. return dbctx def get_dbctx (). "" Get database context "" global dbctx dbctx = db . get_orCreateContext (. return dbctx def init_dbctx (). "" Initialize database context object "" global dbctx if not os . path . exists ( './config.yml' ). raise Exception ( "Please create config.yml first." . with open ( 'config.yml' . as f . for line in f . l = line . rstrip (. parts = l . rsplit ( ':' , 1 . if len ( parts . == 2 . key = " %s _ %s " %( parts [ 0 ], parts [ 1 ]. value = os . getenv ( key . if value <> '' . config . set_value ( key , value . else . raise ValueError (. config . save (. break else . raise ValueError (. dbctx = db . getContext (. return dbctx def init (). "" Init pipeline "" global dbctx init_dbctx (. init_db (. def init_db (). "" Init database "" global db global dbctx try . if not os . path . exists ( './config.yml' ). raise Exception ( "Please create config.yml first." . with open ( 'config.yml' . as f . for line in f . l = line . rstrip (. parts = l . rsplit ( ':' , 1 . if len ( parts . == 2 . key = " %s _ %s " %( parts [ 0 ], parts [ 1 ]. value = os . getenv ( key . if value <> '' . config . set_value ( key , value . else . raise ValueError (. config . save (. break else . raise ValueError (. db = db . getOrCreateDefault (. except Exception as e . print e try . dbctx = db . getContext (. except Exception as e . print e print "Database Context Created!" return print "Failed to Create Database Context!" def init_dbctx (). "" Initialize database context object "" global dbctx try . if not os . path . exists ( './config.yml' ). raise Exception ( "Please create config.yml first." . with open ( 'config.yml' . as f . for line in f . l = line . rstrip (. parts = l . rsplit ( ':' , 1 . if len ( parts . == 2 . key = " %s _ %s " %( parts [ 0 ], parts [ 1 ]. value = os . getenv ( key . if value <> '' . config . set_value ( key , value . else . raise ValueError (. config . save (. break else . raise ValueError (. dbctx = db . getContext (. except ValueError as e . print e print e return print "DB Context Created!" return print "Failed to Create DB Context!" def delete_dbctx (). "" Delete database context object"" global dbctx try . if not os . path . exists ( './config.yml' ). raise Exception ( "Please create config.yml first." . with open ( 'config.yml' . as f . for line in f . l = line . rstrip (. parts = l . rsplit ( ':' , 1 . if len ( parts . == 2 . key = " %s _ %s " %( parts [ 0 ], parts [ 1 ]. value = os . getenv ( key . if value <> '' . config . set_value ( key , value . else . raise ValueError (. config . save (. break else . raise ValueError (. dbctx = db . getContext (. except ValueError as e . print e print e return print e return print "Deleting DB Context Failed!" def delete_dbcontext (). "" Delete database context object"" global dbctx try . if not os . path . exists ( './config.yml' ). raise Exception ( "Please create config.yml first." . with open ( 'config.yml' . as f . for line in f . l = line . rstrip (. parts = l . rsplit ( ':' , 1 . if len ( parts . == 2 . key = " %s _ %s " %( parts [ 0 ], parts [ 1 ]. value = os . getenv ( key . if value <> '' . config . set_value ( key , value . else . raise ValueError (. config . save (. break else . raise ValueError (. dbctx = db . getContext (. except ValueError as e . print e print e return print e return print e return print "Deleting DB Context Failed!" def init_dbcontext (). "" Initialize database context object "" global dbctx try . if not os . path . exists ( './config.yml' ). raise Exception ( "Please create config.yml first." . with open ( 'config.yml' . as f . for line in f . l = line . rstrip (. parts = l . rsplit ( ':' , 1 . if len ( parts . == 2 . key = " %s _ %s " %( parts [ 0 ], parts [ 1 ]. value = os . getenv ( key . if value <> '' . config . set_value ( key , value . else :

The process to integrate Cloud Firestore and pipelinedeals may seem complicated and intimidating. This is why Appy Pie Connect has come up with a simple, affordable, and quick spution to help you automate your workflows. Click on the button below to begin.