以下是我与firebase rtdb listener相关的代码:
import firebase_admin
from firebase_admin import credentials
from firebase_admin import db
class FirebaseConfig:
reference = None
listenerRegistration = None
def __init__(self):
cred = credentials.Certificate("path_to_credentials.json")
firebase_admin.initialize_app(
cred,
{'databaseURL': 'database_url'}
)
self.reference = db.reference("Users")
self.listenerRegistration = self.reference.listen(self.userListener)
def userListener(self, event):
print("Listener Started.")
try:
print(event.data)
updateData() # A function to update our local database
except Exception as e:
raise Exception("Listener Error" + str(e))
def stopListening(self):
print("Closing Listener")
self.listenerRegistration.close()
我现在面临的问题是这个监听器不工作。print语句不打印任何内容。我认为这是因为fastapi。有什么办法可以让它工作吗?
如果它们不能很好地协同工作,您是否有其他解决方案?
暂无答案!
目前还没有任何答案,快来回答吧!