|
|
| 行1: |
行1: |
| − | ==functionsのサンプル==
| + | [[Gcp/Firebase/Firestore/cacheモジュール/基本]] |
| − | *id別にfirestoreのcahesコレクションへ文字列をキャッシュする
| + | |
| − | *cache保持時間を設定できるように
| + | |
| | | | |
| − | cachesのテーブル構成例
| + | [[Gcp/Firebase/Firestore/cacheモジュール/async]] |
| − | id string | data string | unixtime int
| + | |
| − | "hogeid" | "hoge" | 123423451
| + | |
| − | | + | |
| − | functions/index.js
| + | |
| − | <pre>
| + | |
| − | const functions = require('firebase-functions');
| + | |
| − | const admin = require('firebase-admin');
| + | |
| − | admin.initializeApp();
| + | |
| − | exports.setCache = functions
| + | |
| − | .region('asia-northeast1')
| + | |
| − | .https.onRequest((request, response) => {
| + | |
| − | var id = request.query['id'];
| + | |
| − | var cachedata = request.query['cachedata'];
| + | |
| − | const cache = require('./cache.js');
| + | |
| − | cache.registerCallback(onCacheResponse);
| + | |
| − | cache.setCache(admin, cachedata, id);
| + | |
| − | function onCacheResponse(cachedata) {
| + | |
| − | response.send("cachedata=" + cachedata);
| + | |
| − | }
| + | |
| − | });
| + | |
| − | | + | |
| − | exports.getCache = functions
| + | |
| − | .region('asia-northeast1')
| + | |
| − | .https.onRequest((request, response) => {
| + | |
| − | var id = request.query['id'];
| + | |
| − | var cachedata = request.query['cachedata'];
| + | |
| − | var cachelifesec = 0;
| + | |
| − | if (request.query['cachelifesec'] != null) {
| + | |
| − | cachelifesec = parseInt(request.query['cachelifesec']);
| + | |
| − | }
| + | |
| − | const cache = require('./cache.js');
| + | |
| − | cache.registerCallback(onCacheResponse);
| + | |
| − | console.log('cachelifesec=' + cachelifesec);
| + | |
| − | cache.getCache(admin, id, cachelifesec);
| + | |
| − | function onCacheResponse(cachedata) {
| + | |
| − | response.send("cachedata=" + cachedata);
| + | |
| − | }
| + | |
| − | });
| + | |
| − | </pre>
| + | |
| − | | + | |
| − | functions/cache.js
| + | |
| − | <pre>
| + | |
| − | /*
| + | |
| − | Cache設定例
| + | |
| − | const cache = require('./cache.js');
| + | |
| − | cache.registerCallback(onCacheResponse);
| + | |
| − | cache.setCache(admin, cachedata, id);
| + | |
| − | const onCacheResponseSetCache = function(data) {
| + | |
| − | return data; // hogehoge
| + | |
| − | }
| + | |
| − | console.log(cache.getResCallbackSetCache()); // hogehoge
| + | |
| − | Cache取得例
| + | |
| − | const cache = require('./cache.js');
| + | |
| − | cache.registerCallback(onCacheResponse);
| + | |
| − | console.log('cachelifesec=' + cachelifesec);
| + | |
| − | cache.getCache(admin, id, cachelifesec);
| + | |
| − | const onCacheResponseGetCache = function(data) {
| + | |
| − | response.send("data=" + data);
| + | |
| − | }
| + | |
| − | console.log(cache.getResCallbackGetCache()); // hogehoge
| + | |
| − | */
| + | |
| − | | + | |
| − | var mCallbackSetCache;
| + | |
| − | var mResCallbackSetCache = "";
| + | |
| − | var mCallbackGetCache;
| + | |
| − | var mResCallbackGetCache = "";
| + | |
| − | exports.registerCallbackSetCache = function(callback) {
| + | |
| − | mCallbackSetCache = callback;
| + | |
| − | }
| + | |
| − | exports.getResCallbackSetCache = function() {
| + | |
| − | return mResCallbackSetCache;
| + | |
| − | }
| + | |
| − | exports.registerCallbackGetCache = function(callback) {
| + | |
| − | mCallbackGetCache = callback;
| + | |
| − | }
| + | |
| − | exports.getResCallbackGetCache = function() {
| + | |
| − | console.log("getResCallbackGetCache mResCallbackGetCache=" + mResCallbackGetCache);
| + | |
| − | return mResCallbackGetCache;
| + | |
| − | }
| + | |
| − | exports.setCache = function(admin, data, id) {
| + | |
| − | var date = new Date() ;
| + | |
| − | var unixtimems = date.getTime() ;
| + | |
| − | var unixtime = Math.floor( unixtimems / 1000 ) ;
| + | |
| − | console.log('unixtime=' + unixtime);
| + | |
| − | const cache = {
| + | |
| − | id: id,
| + | |
| − | data: data,
| + | |
| − | unixtime: unixtime,
| + | |
| − | };
| + | |
| − | admin.firestore().collection('caches')
| + | |
| − | .doc(id).set(cache)
| + | |
| − | .then((snapshot) =>
| + | |
| − | {
| + | |
| − | if (mCallbackSetCache != null) {
| + | |
| − | mResCallbackSetCache = mCallbackSetCache(data);
| + | |
| − | }
| + | |
| − | });
| + | |
| − | }
| + | |
| − | exports.getCache = function(admin, id, cachelifesec) {
| + | |
| − | var date = new Date() ;
| + | |
| − | var unixtimems = date.getTime() ;
| + | |
| − | var unixtime = Math.floor( unixtimems / 1000 ) ;
| + | |
| − | console.log('unixtime=' + unixtime);
| + | |
| − | var unixtimecachelifesec = unixtime - cachelifesec;
| + | |
| − | console.log('cachelifesec=' + cachelifesec);
| + | |
| − | console.log('unixtimecachelifesec=' +unixtimecachelifesec);
| + | |
| − | admin.firestore().collection('caches')
| + | |
| − | .where('id', '==', id)
| + | |
| − | .where('unixtime', '>', unixtimecachelifesec)
| + | |
| − | .limit(1)
| + | |
| − | .get()
| + | |
| − | .then((snapshot) =>
| + | |
| − | {
| + | |
| − | var caches = snapshot.docs.map(x => x.data());
| + | |
| − | for (let i = 0; i < caches.length; i++) {
| + | |
| − | console.log("ret data=" + caches[i].data);
| + | |
| − | if (mCallbackGetCache != null) {
| + | |
| − | mResCallbackGetCache = mCallbackGetCache(caches[i].data);
| + | |
| − | console.log("getCache ari mResCallbackGetCache=" + mResCallbackGetCache);
| + | |
| − | }
| + | |
| − | return;
| + | |
| − | }
| + | |
| − | if (mCallbackGetCache != null) {
| + | |
| − | mResCallbackGetCache = mCallbackGetCache("");
| + | |
| − | console.log("getCache nasi mResCallbackGetCache=" + mResCallbackGetCache);
| + | |
| − | }
| + | |
| − | });
| + | |
| − | }
| + | |
| − | </pre>
| + | |
| − | | + | |
| − | ==httpアクセスで確認==
| + | |
| − | 10秒でcacheが切れるサンプルurl
| + | |
| − | // cache設定
| + | |
| − | ttps://asia-northeast1-ほげほげ.cloudfunctions.net/setCache?id=hogeid&cachedata=dada1
| + | |
| − | // cache取得
| + | |
| − | ttps://asia-northeast1-ほげほげ.cloudfunctions.net/getCache?id=hogeid&cachelifesec=10
| + | |
| − | | + | |
| − | cacheはid別にfirestoreに格納される。
| + | |
