如何使用python监听Firebase数据库更改？

Question

我正在尝试使用Webhooks将IFTTT服务与Firebase连接。为此，我使用Flask在pythonanywhere上构建了一个python服务器。我这样做很成功，但是我想每次节点中的数据更改时都监听数据库更改，而不必每次都触发IFTTT。为此，我使用了while循环，它正在工作，但是当我尝试更改要从IFTTT监听的节点时，就会出现问题。

from flask import Flask
from flask import request
import requests

app = Flask(__name__)

@app.route('/')
def hello_world():
    return 'Hello!'


@app.route("/SENSORS", methods=["POST","GET"])
def handler1():
    val1= [0,0]

while True:
    username1 = request.get_data()
    username1 = username1.decode("utf-8")
    result1 = [x.strip() for x in username1.split(',')]
    print(result1)

    r1 = requests.get('https://myproject-024.firebaseio.com/USERS/DATA.json')    
    r2 = r1.text                                    #Converting it into text
    r3 = [x.strip() for x in r2.split('"')]         #Removing double quotes
    print(r3)

    #Swapping values to compare the previous and current value
    val1[1] = r2
    val1[1],val1[0] = val1[0],val1[1]

    requests.patch('https://myproject-024.firebaseio.com/USERS.json', json = { "SENSOR" : "1"} )


        if val1[0]!=val1[1]:
            responce = {"value1":"DATA1","value2":"DATA2","value3":"DATA3"}
            requests.post('https://maker.ifttt.com/trigger/USERS/with/key/, data=responce)

Answer 1

您正在使用Firebase REST API从实时数据库中获取数据。 REST API现在提供您使用它的方式，它提供了基本的请求/响应模型，并且始终在您请求的位置返回数据。

要检查数据的更新，可以request and pass an ETag。使用ETag可以防止多次获取相同的数据（节省带宽），但不会为您提供数据更改的实时更新。

要通过regulat HTTP监听该位置上的数据的实时更新，您可以use the REST streaming API，它使用服务器发送的事件（SSE）来告知客户端更新。您会注意到，此API与您现在正在做的非常不同，因此您需要进行很多更改。