I pacchetti di dati di Cloud Firestore sono file di dati statici creati da te da snapshot di documenti e query di Cloud Firestore e pubblicati da te su un CDN, un servizio di hosting o un'altra soluzione. I pacchetti di dati includono sia i documenti che desideri fornire alle tue app client sia i metadati relativi alle query che li hanno generati. Utilizzi gli SDK del client per scaricare i bundle sulla rete o dall'archivio locale, dopodiché carichi i dati del bundle nella cache locale di Cloud Firestore. Una volta caricato un pacchetto, un'app client può eseguire query sui documenti dalla cache locale o dal back-end.
Con i pacchetti di dati, le tue app possono caricare prima i risultati delle query comuni, poiché i documenti sono disponibili all'avvio senza la necessità di chiamate al back-end di Cloud Firestore. Se i risultati vengono caricati dalla cache locale, beneficerai anche di costi di accesso ridotti. Invece di pagare per un milione di istanze dell'app per eseguire query sugli stessi 100 documenti iniziali, paghi solo per le query necessarie per raggruppare quei 100 documenti.
I pacchetti di dati di Cloud Firestore sono progettati per funzionare bene con altri prodotti di backend Firebase. Dai un'occhiata a una soluzione integrata in cui i bundle vengono creati da Cloud Functions e offerti agli utenti con Firebase Hosting.
L'utilizzo di un pacchetto con la tua app comporta tre passaggi:
- Creazione del bundle con Admin SDK
- Servire il pacchetto dalla memoria locale o da un CDN
- Caricamento dei bundle nel client
Che cos'è un pacchetto di dati?
Un pacchetto di dati è un file binario statico creato dall'utente per impacchettare uno o più documenti e/o istantanee di query e da cui è possibile estrarre query denominate . Come vedremo di seguito, gli SDK lato server consentono di creare bundle e gli SDK client forniscono metodi per caricare bundle nella cache locale.
Le query con nome sono una funzionalità particolarmente potente dei bundle. Le query denominate sono oggetti Query
che puoi estrarre da un pacchetto, quindi utilizzarli immediatamente per eseguire query sui dati dalla cache o dal back-end, come fai normalmente in qualsiasi parte della tua app che comunica con Cloud Firestore.
Creazione di bundle di dati sul server
L'utilizzo di Node.js o Java Admin SDK ti offre il controllo completo su cosa includere nei bundle e su come servirli.
Node.js
var bundleId = "latest-stories"; var bundle = firestore.bundle(bundleId); var docSnapshot = await firestore.doc('stories/stories').get(); var querySnapshot = await firestore.collection('stories').get(); // Build the bundle // Note how querySnapshot is named "latest-stories-query" var bundleBuffer = bundle.add(docSnapshot); // Add a document .add('latest-stories-query', querySnapshot) // Add a named query. .build()
Giava
Firestore db = FirestoreClient.getFirestore(app); // Query the 50 latest stories QuerySnapshot latestStories = db.collection("stories") .orderBy("timestamp", Direction.DESCENDING) .limit(50) .get() .get(); // Build the bundle from the query results FirestoreBundle bundle = db.bundleBuilder("latest-stories") .add("latest-stories-query", latestStories) .build();
Pitone
from google.cloud import firestore from google.cloud.firestore_bundle import FirestoreBundle db = firestore.Client() bundle = FirestoreBundle("latest-stories") doc_snapshot = db.collection("stories").document("news-item").get() query = db.collection("stories")._query() # Build the bundle # Note how `query` is named "latest-stories-query" bundle_buffer: str = bundle.add_document(doc_snapshot).add_named_query( "latest-stories-query", query, ).build()
Fornitura di pacchetti di dati
Puoi offrire pacchetti alle tue app client da un CDN o scaricandoli, ad esempio, da Cloud Storage.
Si supponga che il pacchetto creato nella sezione precedente sia stato salvato in un file denominato bundle.txt
e pubblicato su un server. Questo file bundle è come qualsiasi altra risorsa che puoi servire sul Web, come mostrato qui per una semplice app Node.js Express.
const fs = require('fs');
const server = require('http').createServer();
server.on('request', (req, res) => {
const src = fs.createReadStream('./bundle.txt');
src.pipe(res);
});
server.listen(8000);
Caricamento dei bundle di dati nel client
Carichi i pacchetti Firestore recuperandoli da un server remoto, effettuando una richiesta HTTP, chiamando un'API di archiviazione o utilizzando qualsiasi altra tecnica per recuperare i file binari su una rete.
Una volta recuperato, utilizzando l'SDK del client Cloud Firestore, la tua app chiama il metodo loadBundle
, che restituisce un oggetto di tracciamento attività, il cui completamento puoi monitorare proprio come monitori lo stato di una promessa. Al completamento dell'attività di caricamento del bundle, i contenuti del bundle sono disponibili nella cache locale.
ragnatela
// If you are using module bundlers. import firebase from "firebase/app"; import "firebase/firestore"; import "firebase/firestore/bundle"; // This line enables bundle loading as a side effect. // ... async function fetchFromBundle() { // Fetch the bundle from Firebase Hosting, if the CDN cache is hit the 'X-Cache' // response header will be set to 'HIT' const resp = await fetch('/createBundle'); // Load the bundle contents into the Firestore SDK await db.loadBundle(resp.body); // Query the results from the cache // Note: omitting "source: cache" will query the Firestore backend. const query = await db.namedQuery('latest-stories-query'); const storiesSnap = await query.get({ source: 'cache' }); // Use the results // ... }
Rapido
// Utility function for errors when loading bundles. func bundleLoadError(reason: String) -> NSError { return NSError(domain: "FIRSampleErrorDomain", code: 0, userInfo: [NSLocalizedFailureReasonErrorKey: reason]) } // Loads a remote bundle from the provided url. func fetchRemoteBundle(for firestore: Firestore, from url: URL, completion: @escaping ((Result<LoadBundleTaskProgress, Error>) -> ())) { guard let inputStream = InputStream(url: url) else { let error = self.bundleLoadError(reason: "Unable to create stream from the given url: \(url)") completion(.failure(error)) return } // The return value of this function is ignored, but can be used for more granular // bundle load observation. let _ = firestore.loadBundle(inputStream) { (progress, error) in switch (progress, error) { case (.some(let value), .none): if value.state == .success { completion(.success(value)) } else { let concreteError = self.bundleLoadError( reason: "Expected bundle load to be completed, but got \(value.state) instead" ) completion(.failure(concreteError)) } case (.none, .some(let concreteError)): completion(.failure(concreteError)) case (.none, .none): let concreteError = self.bundleLoadError(reason: "Operation failed, but returned no error.") completion(.failure(concreteError)) case (.some(let value), .some(let concreteError)): let concreteError = self.bundleLoadError( reason: "Operation returned error \(concreteError) with nonnull progress: \(value)" ) completion(.failure(concreteError)) } } } // Fetches a specific named query from the provided bundle. func loadQuery(named queryName: String, fromRemoteBundle bundleURL: URL, with store: Firestore, completion: @escaping ((Result<Query, Error>) -> ())) { fetchRemoteBundle(for: store, from: bundleURL) { (result) in switch result { case .success: store.getQuery(named: queryName) { query in if let query = query { completion(.success(query)) } else { completion( .failure( self.bundleLoadError(reason: "Could not find query named \(queryName)") ) ) } } case .failure(let error): completion(.failure(error)) } } } // Load a query and fetch its results from a bundle. func runStoriesQuery() { let queryName = "latest-stories-query" let firestore = Firestore.firestore() let remoteBundle = URL(string: "https://example.com/createBundle")! loadQuery(named: queryName, fromRemoteBundle: remoteBundle, with: firestore) { (result) in switch result { case .failure(let error): print(error) case .success(let query): query.getDocuments { (snapshot, error) in // handle query results } } } }
Obiettivo-C
// Utility function for errors when loading bundles. - (NSError *)bundleLoadErrorWithReason:(NSString *)reason { return [NSError errorWithDomain:@"FIRSampleErrorDomain" code:0 userInfo:@{NSLocalizedFailureReasonErrorKey: reason}]; } // Loads a remote bundle from the provided url. - (void)fetchRemoteBundleForFirestore:(FIRFirestore *)firestore fromURL:(NSURL *)url completion:(void (^)(FIRLoadBundleTaskProgress *_Nullable, NSError *_Nullable))completion { NSInputStream *inputStream = [NSInputStream inputStreamWithURL:url]; if (inputStream == nil) { // Unable to create input stream. NSError *error = [self bundleLoadErrorWithReason: [NSString stringWithFormat:@"Unable to create stream from the given url: %@", url]]; completion(nil, error); return; } [firestore loadBundleStream:inputStream completion:^(FIRLoadBundleTaskProgress * _Nullable progress, NSError * _Nullable error) { if (progress == nil) { completion(nil, error); return; } if (progress.state == FIRLoadBundleTaskStateSuccess) { completion(progress, nil); } else { NSError *concreteError = [self bundleLoadErrorWithReason: [NSString stringWithFormat: @"Expected bundle load to be completed, but got %ld instead", (long)progress.state]]; completion(nil, concreteError); } completion(nil, nil); }]; } // Loads a bundled query. - (void)loadQueryNamed:(NSString *)queryName fromRemoteBundleURL:(NSURL *)url withFirestore:(FIRFirestore *)firestore completion:(void (^)(FIRQuery *_Nullable, NSError *_Nullable))completion { [self fetchRemoteBundleForFirestore:firestore fromURL:url completion:^(FIRLoadBundleTaskProgress *progress, NSError *error) { if (error != nil) { completion(nil, error); return; } [firestore getQueryNamed:queryName completion:^(FIRQuery *query) { if (query == nil) { NSString *errorReason = [NSString stringWithFormat:@"Could not find query named %@", queryName]; NSError *error = [self bundleLoadErrorWithReason:errorReason]; completion(nil, error); return; } completion(query, nil); }]; }]; } - (void)runStoriesQuery { NSString *queryName = @"latest-stories-query"; FIRFirestore *firestore = [FIRFirestore firestore]; NSURL *bundleURL = [NSURL URLWithString:@"https://example.com/createBundle"]; [self loadQueryNamed:queryName fromRemoteBundleURL:bundleURL withFirestore:firestore completion:^(FIRQuery *query, NSError *error) { // Handle query results }]; }
Kotlin+KTX
@Throws(IOException::class) fun getBundleStream(urlString: String?): InputStream { val url = URL(urlString) val connection = url.openConnection() as HttpURLConnection return connection.inputStream } @Throws(IOException::class) fun fetchFromBundle() { val bundleStream = getBundleStream("https://example.com/createBundle") val loadTask = db.loadBundle(bundleStream) // Chain the following tasks // 1) Load the bundle // 2) Get the named query from the local cache // 3) Execute a get() on the named query loadTask.continueWithTask<Query> { task -> // Close the stream bundleStream.close() // Calling .result propagates errors val progress = task.getResult(Exception::class.java) // Get the named query from the bundle cache db.getNamedQuery("latest-stories-query") }.continueWithTask { task -> val query = task.getResult(Exception::class.java)!! // get() the query results from the cache query.get(Source.CACHE) }.addOnCompleteListener { task -> if (!task.isSuccessful) { Log.w(TAG, "Bundle loading failed", task.exception) return@addOnCompleteListener } // Get the QuerySnapshot from the bundle val storiesSnap = task.result // Use the results // ... } }
Java
public InputStream getBundleStream(String urlString) throws IOException { URL url = new URL(urlString); HttpURLConnection connection = (HttpURLConnection) url.openConnection(); return connection.getInputStream(); } public void fetchBundleFrom() throws IOException { final InputStream bundleStream = getBundleStream("https://example.com/createBundle"); LoadBundleTask loadTask = db.loadBundle(bundleStream); // Chain the following tasks // 1) Load the bundle // 2) Get the named query from the local cache // 3) Execute a get() on the named query loadTask.continueWithTask(new Continuation<LoadBundleTaskProgress, Task<Query>>() { @Override public Task<Query> then(@NonNull Task<LoadBundleTaskProgress> task) throws Exception { // Close the stream bundleStream.close(); // Calling getResult() propagates errors LoadBundleTaskProgress progress = task.getResult(Exception.class); // Get the named query from the bundle cache return db.getNamedQuery("latest-stories-query"); } }).continueWithTask(new Continuation<Query, Task<QuerySnapshot>>() { @Override public Task<QuerySnapshot> then(@NonNull Task<Query> task) throws Exception { Query query = task.getResult(Exception.class); // get() the query results from the cache return query.get(Source.CACHE); } }).addOnCompleteListener(new OnCompleteListener<QuerySnapshot>() { @Override public void onComplete(@NonNull Task<QuerySnapshot> task) { if (!task.isSuccessful()) { Log.w(TAG, "Bundle loading failed", task.getException()); return; } // Get the QuerySnapshot from the bundle QuerySnapshot storiesSnap = task.getResult(); // Use the results // ... } }); }
C++
db->LoadBundle("bundle_name", [](const LoadBundleTaskProgress& progress) { switch(progress.state()) { case LoadBundleTaskProgress::State::kError: { // The bundle load has errored. Handle the error in the returned future. return; } case LoadBundleTaskProgress::State::kInProgress: { std::cout << "Bytes loaded from bundle: " << progress.bytes_loaded() << std::endl; break; } case LoadBundleTaskProgress::State::kSuccess: { std::cout << "Bundle load succeeeded" << std::endl; break; } } }).OnCompletion([db](const Future<LoadBundleTaskProgress>& future) { if (future.error() != Error::kErrorOk) { // Handle error... return; } const std::string& query_name = "latest_stories_query"; db->NamedQuery(query_name).OnCompletion([](const Future<Query>& query_future){ if (query_future.error() != Error::kErrorOk) { // Handle error... return; } const Query* query = query_future.result(); query->Get().OnCompletion([](const Future<QuerySnapshot> &){ // ... }); }); });
Tieni presente che se carichi una query denominata da un pacchetto creato meno di 30 minuti prima, una volta utilizzata per leggere dal back-end anziché dalla cache, pagherai solo per le letture del database necessarie per aggiornare i documenti in modo che corrispondano a ciò che è archiviato nel back-end ; cioè paghi solo per i delta.
E dopo?
Fare riferimento alla documentazione di riferimento dell'API dei bundle di dati per il lato client ( Apple , Android , Web ) e il lato server ( Node.js ).
Se non l'hai già fatto, dai un'occhiata alla soluzione Cloud Functions e Firebase Hosting per la creazione e la pubblicazione di bundle .
I pacchetti di dati di Cloud Firestore sono file di dati statici creati da te da snapshot di documenti e query di Cloud Firestore e pubblicati da te su un CDN, un servizio di hosting o un'altra soluzione. I pacchetti di dati includono sia i documenti che desideri fornire alle tue app client sia i metadati relativi alle query che li hanno generati. Utilizzi gli SDK del client per scaricare i bundle sulla rete o dall'archivio locale, dopodiché carichi i dati del bundle nella cache locale di Cloud Firestore. Una volta caricato un pacchetto, un'app client può eseguire query sui documenti dalla cache locale o dal back-end.
Con i pacchetti di dati, le tue app possono caricare prima i risultati delle query comuni, poiché i documenti sono disponibili all'avvio senza la necessità di chiamate al back-end di Cloud Firestore. Se i risultati vengono caricati dalla cache locale, beneficerai anche di costi di accesso ridotti. Invece di pagare per un milione di istanze dell'app per eseguire query sugli stessi 100 documenti iniziali, paghi solo per le query necessarie per raggruppare quei 100 documenti.
I pacchetti di dati di Cloud Firestore sono progettati per funzionare bene con altri prodotti di backend Firebase. Dai un'occhiata a una soluzione integrata in cui i bundle vengono creati da Cloud Functions e offerti agli utenti con Firebase Hosting.
L'utilizzo di un pacchetto con la tua app comporta tre passaggi:
- Creazione del bundle con Admin SDK
- Servire il pacchetto dalla memoria locale o da un CDN
- Caricamento dei bundle nel client
Che cos'è un pacchetto di dati?
Un pacchetto di dati è un file binario statico creato dall'utente per impacchettare uno o più documenti e/o istantanee di query e da cui è possibile estrarre query denominate . Come vedremo di seguito, gli SDK lato server consentono di creare bundle e gli SDK client forniscono metodi per caricare bundle nella cache locale.
Le query con nome sono una funzionalità particolarmente potente dei bundle. Le query denominate sono oggetti Query
che puoi estrarre da un pacchetto, quindi utilizzarli immediatamente per eseguire query sui dati dalla cache o dal back-end, come fai normalmente in qualsiasi parte della tua app che comunica con Cloud Firestore.
Creazione di bundle di dati sul server
L'utilizzo di Node.js o Java Admin SDK ti offre il controllo completo su cosa includere nei bundle e su come servirli.
Node.js
var bundleId = "latest-stories"; var bundle = firestore.bundle(bundleId); var docSnapshot = await firestore.doc('stories/stories').get(); var querySnapshot = await firestore.collection('stories').get(); // Build the bundle // Note how querySnapshot is named "latest-stories-query" var bundleBuffer = bundle.add(docSnapshot); // Add a document .add('latest-stories-query', querySnapshot) // Add a named query. .build()
Giava
Firestore db = FirestoreClient.getFirestore(app); // Query the 50 latest stories QuerySnapshot latestStories = db.collection("stories") .orderBy("timestamp", Direction.DESCENDING) .limit(50) .get() .get(); // Build the bundle from the query results FirestoreBundle bundle = db.bundleBuilder("latest-stories") .add("latest-stories-query", latestStories) .build();
Pitone
from google.cloud import firestore from google.cloud.firestore_bundle import FirestoreBundle db = firestore.Client() bundle = FirestoreBundle("latest-stories") doc_snapshot = db.collection("stories").document("news-item").get() query = db.collection("stories")._query() # Build the bundle # Note how `query` is named "latest-stories-query" bundle_buffer: str = bundle.add_document(doc_snapshot).add_named_query( "latest-stories-query", query, ).build()
Fornitura di pacchetti di dati
Puoi offrire pacchetti alle tue app client da un CDN o scaricandoli, ad esempio, da Cloud Storage.
Si supponga che il pacchetto creato nella sezione precedente sia stato salvato in un file denominato bundle.txt
e pubblicato su un server. Questo file bundle è come qualsiasi altra risorsa che puoi servire sul Web, come mostrato qui per una semplice app Node.js Express.
const fs = require('fs');
const server = require('http').createServer();
server.on('request', (req, res) => {
const src = fs.createReadStream('./bundle.txt');
src.pipe(res);
});
server.listen(8000);
Caricamento dei bundle di dati nel client
Carichi i pacchetti Firestore recuperandoli da un server remoto, effettuando una richiesta HTTP, chiamando un'API di archiviazione o utilizzando qualsiasi altra tecnica per recuperare i file binari su una rete.
Una volta recuperato, utilizzando l'SDK del client Cloud Firestore, la tua app chiama il metodo loadBundle
, che restituisce un oggetto di tracciamento attività, il cui completamento puoi monitorare proprio come monitori lo stato di una promessa. Al completamento dell'attività di caricamento del bundle, i contenuti del bundle sono disponibili nella cache locale.
ragnatela
// If you are using module bundlers. import firebase from "firebase/app"; import "firebase/firestore"; import "firebase/firestore/bundle"; // This line enables bundle loading as a side effect. // ... async function fetchFromBundle() { // Fetch the bundle from Firebase Hosting, if the CDN cache is hit the 'X-Cache' // response header will be set to 'HIT' const resp = await fetch('/createBundle'); // Load the bundle contents into the Firestore SDK await db.loadBundle(resp.body); // Query the results from the cache // Note: omitting "source: cache" will query the Firestore backend. const query = await db.namedQuery('latest-stories-query'); const storiesSnap = await query.get({ source: 'cache' }); // Use the results // ... }
Rapido
// Utility function for errors when loading bundles. func bundleLoadError(reason: String) -> NSError { return NSError(domain: "FIRSampleErrorDomain", code: 0, userInfo: [NSLocalizedFailureReasonErrorKey: reason]) } // Loads a remote bundle from the provided url. func fetchRemoteBundle(for firestore: Firestore, from url: URL, completion: @escaping ((Result<LoadBundleTaskProgress, Error>) -> ())) { guard let inputStream = InputStream(url: url) else { let error = self.bundleLoadError(reason: "Unable to create stream from the given url: \(url)") completion(.failure(error)) return } // The return value of this function is ignored, but can be used for more granular // bundle load observation. let _ = firestore.loadBundle(inputStream) { (progress, error) in switch (progress, error) { case (.some(let value), .none): if value.state == .success { completion(.success(value)) } else { let concreteError = self.bundleLoadError( reason: "Expected bundle load to be completed, but got \(value.state) instead" ) completion(.failure(concreteError)) } case (.none, .some(let concreteError)): completion(.failure(concreteError)) case (.none, .none): let concreteError = self.bundleLoadError(reason: "Operation failed, but returned no error.") completion(.failure(concreteError)) case (.some(let value), .some(let concreteError)): let concreteError = self.bundleLoadError( reason: "Operation returned error \(concreteError) with nonnull progress: \(value)" ) completion(.failure(concreteError)) } } } // Fetches a specific named query from the provided bundle. func loadQuery(named queryName: String, fromRemoteBundle bundleURL: URL, with store: Firestore, completion: @escaping ((Result<Query, Error>) -> ())) { fetchRemoteBundle(for: store, from: bundleURL) { (result) in switch result { case .success: store.getQuery(named: queryName) { query in if let query = query { completion(.success(query)) } else { completion( .failure( self.bundleLoadError(reason: "Could not find query named \(queryName)") ) ) } } case .failure(let error): completion(.failure(error)) } } } // Load a query and fetch its results from a bundle. func runStoriesQuery() { let queryName = "latest-stories-query" let firestore = Firestore.firestore() let remoteBundle = URL(string: "https://example.com/createBundle")! loadQuery(named: queryName, fromRemoteBundle: remoteBundle, with: firestore) { (result) in switch result { case .failure(let error): print(error) case .success(let query): query.getDocuments { (snapshot, error) in // handle query results } } } }
Obiettivo-C
// Utility function for errors when loading bundles. - (NSError *)bundleLoadErrorWithReason:(NSString *)reason { return [NSError errorWithDomain:@"FIRSampleErrorDomain" code:0 userInfo:@{NSLocalizedFailureReasonErrorKey: reason}]; } // Loads a remote bundle from the provided url. - (void)fetchRemoteBundleForFirestore:(FIRFirestore *)firestore fromURL:(NSURL *)url completion:(void (^)(FIRLoadBundleTaskProgress *_Nullable, NSError *_Nullable))completion { NSInputStream *inputStream = [NSInputStream inputStreamWithURL:url]; if (inputStream == nil) { // Unable to create input stream. NSError *error = [self bundleLoadErrorWithReason: [NSString stringWithFormat:@"Unable to create stream from the given url: %@", url]]; completion(nil, error); return; } [firestore loadBundleStream:inputStream completion:^(FIRLoadBundleTaskProgress * _Nullable progress, NSError * _Nullable error) { if (progress == nil) { completion(nil, error); return; } if (progress.state == FIRLoadBundleTaskStateSuccess) { completion(progress, nil); } else { NSError *concreteError = [self bundleLoadErrorWithReason: [NSString stringWithFormat: @"Expected bundle load to be completed, but got %ld instead", (long)progress.state]]; completion(nil, concreteError); } completion(nil, nil); }]; } // Loads a bundled query. - (void)loadQueryNamed:(NSString *)queryName fromRemoteBundleURL:(NSURL *)url withFirestore:(FIRFirestore *)firestore completion:(void (^)(FIRQuery *_Nullable, NSError *_Nullable))completion { [self fetchRemoteBundleForFirestore:firestore fromURL:url completion:^(FIRLoadBundleTaskProgress *progress, NSError *error) { if (error != nil) { completion(nil, error); return; } [firestore getQueryNamed:queryName completion:^(FIRQuery *query) { if (query == nil) { NSString *errorReason = [NSString stringWithFormat:@"Could not find query named %@", queryName]; NSError *error = [self bundleLoadErrorWithReason:errorReason]; completion(nil, error); return; } completion(query, nil); }]; }]; } - (void)runStoriesQuery { NSString *queryName = @"latest-stories-query"; FIRFirestore *firestore = [FIRFirestore firestore]; NSURL *bundleURL = [NSURL URLWithString:@"https://example.com/createBundle"]; [self loadQueryNamed:queryName fromRemoteBundleURL:bundleURL withFirestore:firestore completion:^(FIRQuery *query, NSError *error) { // Handle query results }]; }
Kotlin+KTX
@Throws(IOException::class) fun getBundleStream(urlString: String?): InputStream { val url = URL(urlString) val connection = url.openConnection() as HttpURLConnection return connection.inputStream } @Throws(IOException::class) fun fetchFromBundle() { val bundleStream = getBundleStream("https://example.com/createBundle") val loadTask = db.loadBundle(bundleStream) // Chain the following tasks // 1) Load the bundle // 2) Get the named query from the local cache // 3) Execute a get() on the named query loadTask.continueWithTask<Query> { task -> // Close the stream bundleStream.close() // Calling .result propagates errors val progress = task.getResult(Exception::class.java) // Get the named query from the bundle cache db.getNamedQuery("latest-stories-query") }.continueWithTask { task -> val query = task.getResult(Exception::class.java)!! // get() the query results from the cache query.get(Source.CACHE) }.addOnCompleteListener { task -> if (!task.isSuccessful) { Log.w(TAG, "Bundle loading failed", task.exception) return@addOnCompleteListener } // Get the QuerySnapshot from the bundle val storiesSnap = task.result // Use the results // ... } }
Java
public InputStream getBundleStream(String urlString) throws IOException { URL url = new URL(urlString); HttpURLConnection connection = (HttpURLConnection) url.openConnection(); return connection.getInputStream(); } public void fetchBundleFrom() throws IOException { final InputStream bundleStream = getBundleStream("https://example.com/createBundle"); LoadBundleTask loadTask = db.loadBundle(bundleStream); // Chain the following tasks // 1) Load the bundle // 2) Get the named query from the local cache // 3) Execute a get() on the named query loadTask.continueWithTask(new Continuation<LoadBundleTaskProgress, Task<Query>>() { @Override public Task<Query> then(@NonNull Task<LoadBundleTaskProgress> task) throws Exception { // Close the stream bundleStream.close(); // Calling getResult() propagates errors LoadBundleTaskProgress progress = task.getResult(Exception.class); // Get the named query from the bundle cache return db.getNamedQuery("latest-stories-query"); } }).continueWithTask(new Continuation<Query, Task<QuerySnapshot>>() { @Override public Task<QuerySnapshot> then(@NonNull Task<Query> task) throws Exception { Query query = task.getResult(Exception.class); // get() the query results from the cache return query.get(Source.CACHE); } }).addOnCompleteListener(new OnCompleteListener<QuerySnapshot>() { @Override public void onComplete(@NonNull Task<QuerySnapshot> task) { if (!task.isSuccessful()) { Log.w(TAG, "Bundle loading failed", task.getException()); return; } // Get the QuerySnapshot from the bundle QuerySnapshot storiesSnap = task.getResult(); // Use the results // ... } }); }
C++
db->LoadBundle("bundle_name", [](const LoadBundleTaskProgress& progress) { switch(progress.state()) { case LoadBundleTaskProgress::State::kError: { // The bundle load has errored. Handle the error in the returned future. return; } case LoadBundleTaskProgress::State::kInProgress: { std::cout << "Bytes loaded from bundle: " << progress.bytes_loaded() << std::endl; break; } case LoadBundleTaskProgress::State::kSuccess: { std::cout << "Bundle load succeeeded" << std::endl; break; } } }).OnCompletion([db](const Future<LoadBundleTaskProgress>& future) { if (future.error() != Error::kErrorOk) { // Handle error... return; } const std::string& query_name = "latest_stories_query"; db->NamedQuery(query_name).OnCompletion([](const Future<Query>& query_future){ if (query_future.error() != Error::kErrorOk) { // Handle error... return; } const Query* query = query_future.result(); query->Get().OnCompletion([](const Future<QuerySnapshot> &){ // ... }); }); });
Tieni presente che se carichi una query denominata da un pacchetto creato meno di 30 minuti prima, una volta utilizzata per leggere dal back-end anziché dalla cache, pagherai solo per le letture del database necessarie per aggiornare i documenti in modo che corrispondano a ciò che è archiviato nel back-end ; cioè paghi solo per i delta.
E dopo?
Fare riferimento alla documentazione di riferimento dell'API dei bundle di dati per il lato client ( Apple , Android , Web ) e il lato server ( Node.js ).
Se non l'hai già fatto, dai un'occhiata alla soluzione Cloud Functions e Firebase Hosting per la creazione e la pubblicazione di bundle .