change based on name filter
This commit is contained in:
@@ -1,8 +1,9 @@
|
|||||||
import firebase_admin
|
import firebase_admin
|
||||||
from firebase_admin import credentials, firestore
|
from firebase_admin import credentials, firestore
|
||||||
import os
|
import os
|
||||||
|
from google.cloud.firestore_v1.base_query import FieldFilter
|
||||||
|
|
||||||
key_path = os.getcwd() + '/scripts/keys/hpos-af3cc-firebase-adminsdk-n261k-2bfd463ec0.json'
|
key_path = os.getcwd() + '/scripts/keys/hpos-preprod-firebase-adminsdk-d6jjt-ae42ad0f67.json'
|
||||||
# Replace 'path/to/your/serviceAccountKey.json' with the actual path to your service account JSON file
|
# Replace 'path/to/your/serviceAccountKey.json' with the actual path to your service account JSON file
|
||||||
cred = credentials.Certificate(key_path)
|
cred = credentials.Certificate(key_path)
|
||||||
firebase_admin.initialize_app(cred)
|
firebase_admin.initialize_app(cred)
|
||||||
@@ -10,11 +11,11 @@ def move_documents(source_collection):
|
|||||||
db = firestore.client()
|
db = firestore.client()
|
||||||
|
|
||||||
# Get all documents from the source collection
|
# Get all documents from the source collection
|
||||||
source_docs = db.collection(source_collection).get()
|
source_docs = db.collection(source_collection).where(filter=FieldFilter("name", "==", " S2-A-R1")).stream()
|
||||||
|
|
||||||
for doc in source_docs:
|
for doc in source_docs:
|
||||||
# Extract the document ID
|
# Extract the document ID
|
||||||
doc_id = doc.id
|
doc_id = doc.id
|
||||||
|
print(doc_id)
|
||||||
|
|
||||||
# Get the document data
|
# Get the document data
|
||||||
doc_data = doc.to_dict()
|
doc_data = doc.to_dict()
|
||||||
|
|||||||
Reference in New Issue
Block a user