Firebase Admin von einem Endpunkt in Java

Question

Ich versuche, Firebase Realtime DB über Admin SDK von einem Endpunkt in Java zuzugreifen. Die Authentifizierung scheint erfolgreich zu sein, die Abfrage hat jedoch keine Auswirkungen. Es tritt kein Fehler auf und die Listener werden nicht aufgerufen. Die Firebase-Regel ist beschreibbar (mit Simulator gesichert).

Firebase db:

mydbid 
     +---users 
      +---user0 
       +---email:default@gmail.com 

Endpoint def:

@Api(
    name = "firebaseTestEndpoint", 
    version = "v1", 
    description = "Firebase admin test endpoint.") 

public class FirebaseTestService { 
    private static final Logger log = 
    Logger.getLogger(FirebaseTestService.class.getName()); 
    static { 
     log.setLevel(Level.INFO); 
    } 

@ApiMethod(httpMethod = HttpMethod.POST) 
public void connectToFirebase(@Named("id") String id, 
           ServletContext servletContext) { 

    Map<String, Object> authVars = new HashMap<String, Object>(); 
    authVars.put("uid", "admin"); 

    try { 
     FirebaseOptions options = new FirebaseOptions.Builder() 
       .setDatabaseUrl("https://mydbid.firebaseio.com")    
       .setCredential(FirebaseCredentials.fromCertificate(
        servletContext.getResourceAsStream(
         "/WEB-INF/firebase-credentials.json"))) 
       .setDatabaseAuthVariableOverride(authVars) 
       .build(); 
     FirebaseApp app = FirebaseApp.initializeApp(options); 
     DatabaseReference ref = 
    FirebaseDatabase.getInstance().getReference("https://stackoverflow.com/users/user0/email"); 
     ValueEventListener valueEventListener = 
    ref.addValueEventListener(new ValueEventListener() { 
      @Override 
      public void onDataChange(DataSnapshot arg0) { 
       log.info(arg0.getRef().getPath().toString() + 
         " changed to " + arg0.getValue(String.class)); 
      } 

      @Override 
      public void onCancelled(DatabaseError arg0) { 
       log.info("cancelled"); 
      } 
     }); 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
} 

@ApiMethod(httpMethod = HttpMethod.POST) 
public void updateEmail(@Named("id") String id) { 

    Map<String,Object> values = new HashMap<String,Object>(); 
    values.put("email", "updated@gmail.com"); 
    try { 
     FirebaseDatabase.getInstance().getReference("https://stackoverflow.com/users/user0") 
     .updateChildren(values, new DatabaseReference.CompletionListener() { 
      public void onComplete(DatabaseError databaseError, 
            DatabaseReference databaseReference) { 
       if (databaseError != null) { 
        throw databaseError.toException(); 
       } 
       log.info("update completed."); 
      } 
     }); 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
} 
} 

appengine-web.xml (bezogen Teile):

<basic-scaling> 
    <max-instances>2</max-instances> 
</basic-scaling> 

web.xml (bezogen Teile; ein Raum eingefügt vor *):

<servlet> 
    <servlet-name>EndpointsServlet</servlet-name> 
    <servlet-class>com.google.api.server.spi.EndpointsServlet</servlet-class> 
    <init-param> 
    <param-name>services</param-name> 
    <param-value>mypackage.FirebaseTestService</param-value> 
    </init-param> 
</servlet> 
<servlet-mapping> 
    <servlet-name>EndpointsServlet</servlet-name> 
    <url-pattern>/_ah/api/ *</url-pattern> 
</servlet-mapping> 

<servlet> 
    <servlet-name>SystemServiceServlet</servlet-name> 
    <servlet-class>com.google.api.server.spi.SystemServiceServlet</servlet-class> 
    <init-param> 
    <param-name>services</param-name> 
    <param-value>mypackage.FirebaseTestService</param-value> 
    </init-param> 
</servlet> 
<servlet-mapping> 
    <servlet-name>SystemServiceServlet</servlet-name> 
    <url-pattern>/_ah/spi/ *</url-pattern> 
</servlet-mapping> 

Getestet im APIs Explorer, auf den Aufruf connectToFirebase() folgt eine Anforderung an _ah/background, aber updateEmail() nicht. Was ist los?

Answer 1

Um Firebase-Listener in AppEngine verwenden zu können, ändern Sie die grundlegende Skalierung in manuelle Skalierung.

Wenn Sie Basic oder Autoscaling von AppEngine-Instanzen verwenden möchten, ändern Sie die Firebase-Listener in REST-Aufrufe.