Skip to content

Latest commit

 

History

History
126 lines (92 loc) · 2.87 KB

File metadata and controls

126 lines (92 loc) · 2.87 KB

Python SDK Usage

The Python Server SDK is used for backend/server environments and utilizes Google Application Default Credentials in most Google Cloud environments.

Writing Data

Set a Document

Creates a document if it does not exist or overwrites it if it does. You can also specify a merge option to only update provided fields.

city_ref = db.collection("cities").document("LA")

# Create/Overwrite
city_ref.set({
    "name": "Los Angeles",
    "state": "CA",
    "country": "USA"
})

# Merge
city_ref.set({"population": 3900000}, merge=True)

Add a Document with Auto-ID

Use when you don't care about the document ID and want Firestore to automatically generate one.

update_time, city_ref = db.collection("cities").add({
    "name": "Tokyo",
    "country": "Japan"
})
print("Document written with ID: ", city_ref.id)

Update a Document

Update some fields of an existing document without overwriting the entire document. Fails if the document doesn't exist.

city_ref = db.collection("cities").document("LA")
city_ref.update({
    "capital": True
})

Transactions

Perform an atomic read-modify-write operation.

from google.cloud.firestore import Transaction

transaction = db.transaction()
city_ref = db.collection("cities").document("SF")

@firestore.transactional
def update_in_transaction(transaction, city_ref):
    snapshot = city_ref.get(transaction=transaction)
    if not snapshot.exists:
        raise Exception("Document does not exist!")
    
    new_population = snapshot.get("population") + 1
    transaction.update(city_ref, {"population": new_population})

update_in_transaction(transaction, city_ref)

Reading Data

Get a Single Document

doc_ref = db.collection("cities").document("SF")
doc = doc_ref.get()

if doc.exists:
    print(f"Document data: {doc.to_dict()}")
else:
    print("No such document!")

Get Multiple Documents

Fetches all documents in a query or collection once.

docs = db.collection("cities").stream()

for doc in docs:
    print(f"{doc.id} => {doc.to_dict()}")

Queries

Simple and Compound Queries

Use .where() to combine filters safely. Stack .where() calls for compound queries.

from google.cloud.firestore import FieldFilter

cities_ref = db.collection("cities")

# Simple equality
query_1 = cities_ref.where(filter=FieldFilter("state", "==", "CA"))

# Compound (AND)
query_2 = cities_ref.where(
    filter=FieldFilter("state", "==", "CA")
).where(
    filter=FieldFilter("population", ">", 1000000)
)

Order and Limit

Sort and limit results cleanly.

query = cities_ref.order_by("name").limit(3)

Pipeline Queries

You can use pipeline queries to perform complex queries.

pipeline = client.pipeline().collection("users")
for result in pipeline.execute():
    print(f"{result.id} => {result.data()}")