如何访问使用 FCM API 发送的 Firebase Cloud 消息的详细信息？

Question

我构建了一个原型 lambda 函数，它可以根据 Firebase 中存储的规则查询数据库来发送自动推送通知。该功能计划每天运行。通过下面的这个函数，我调用消息传递对象

private void sentAutomatedMessages(List<String> tokens, CardAbandonmentRule rule) {

    for (String token : tokens) {

        //Create Messaging object for every user that fits in this user
        Messaging msgHandler = new Messaging(rule.getTitle(), rule.getMessage(), token);
        try {
            msgHandler.handleSingleDevicePush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

类定义和发送推送通知的方法 =>

public class Messaging {

private static final String PROJECT_ID = "<project_id>";
private static final String BASE_URL = "https://fcm.googleapis.com";
private static final String FCM_SEND_ENDPOINT = "/v1/projects/" + PROJECT_ID + "/messages:send";

private static final String MESSAGING_SCOPE = "https://www.googleapis.com/auth/firebase.messaging";
private static final String[] SCOPES = {MESSAGING_SCOPE};

private String title;
private String message;
private String token;

public Messaging(String title, String message, String token) {
    this.title = title;
    this.message = message;
    this.token = token; // <FCM_token>
}

/**
 * Retrieve a valid access token that can be use to authorize requests to the FCM REST
 * API.
 *
 * @return Access token.
 * @throws IOException
 */
private static String getAccessToken() throws IOException {
    GoogleCredential googleCredential = GoogleCredential
            .fromStream(new FileInputStream("<firebase_private_key.json>"))
            .createScoped(Arrays.asList(SCOPES));
    googleCredential.refreshToken();

    return googleCredential.getAccessToken();
}

/**
 * Create HttpURLConnection that can be used for both retrieving and publishing.
 *
 * @return Base HttpURLConnection.
 * @throws IOException
 */
private static HttpURLConnection getConnection() throws IOException {
    // [START use_access_token]
    URL url = new URL(BASE_URL + FCM_SEND_ENDPOINT);
    HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
    String accessToken = getAccessToken();
    System.out.println(accessToken);
    httpURLConnection.setRequestProperty("Authorization", "Bearer " + accessToken);
    httpURLConnection.setRequestProperty("Content-Type", "application/json; UTF-8");
    return httpURLConnection;
    // [END use_access_token]
}

/**
 * Construct the body of a notification message request.
 *
 * @return JSON of notification message.
 */
private JsonObject buildNotificationMessage() {
    JsonObject jNotification = new JsonObject();
    jNotification.addProperty("title", this.title);
    jNotification.addProperty("body", this.message);

    JsonObject jMessage = new JsonObject();
    jMessage.add("notification", jNotification);
    jMessage.addProperty("token", this.token);


    JsonObject jFcm = new JsonObject();
    jFcm.add("message", jMessage);

    return jFcm;
}

/**
 * Send request to FCM message using HTTP.
 *
 * @param fcmMessage Body of the HTTP request.
 * @throws IOException
 */
private static void sendtoSingleDevice(JsonObject fcmMessage) throws IOException {
    HttpURLConnection connection = getConnection();
    connection.setDoOutput(true);
    DataOutputStream outputStream = new DataOutputStream(connection.getOutputStream());
    outputStream.writeBytes(fcmMessage.toString());
    outputStream.flush();
    outputStream.close();

    int responseCode = connection.getResponseCode();
    if (responseCode == 200) {
        String response = inputstreamToString(connection.getInputStream());
        System.out.println("Message sent to Firebase for delivery, response:");
        System.out.println(response);
    } else {
        System.out.println("Unable to send message to Firebase:");
        String response = inputstreamToString(connection.getErrorStream());
        System.out.println(response);
    }
}

/**
 * Public method to send Push Notification
 *
 * @throws IOException
 */
public void handleSingleDevicePush() throws IOException {
    JsonObject notificationMessage = buildNotificationMessage();
    sendtoSingleDevice(notificationMessage);
}

运行后buildNotificationMessage()，对象形成如下例所示。

// Example Notification Message to send over HTTP
{
  "message": {
    "notification": {
      "title": "title",
      "body": "body"
    },
    "token": "<FCM_token>"
  }
}

响应是=>

{  "name": "projects/<project_id>/messages/1542324302450893"}

我必须开发一个仪表板来列出已发送的消息、打开率和分析。但是，我需要一些指导。

1 - 我可以用FCM REST APIname的响应来做什么？我在文档中没有看到任何用于获取消息详细信息的内容。

2 - 是否有更好的方法为多个唯一的 FCM 令牌发送批量消息？我看到一些有关设备组的内容，但 Firebase 说它有不同的目的。

通常，“组”是指属于单个用户的一组不同设备。

谢谢

Answer 1

在我联系 Firebase 支持后，他们建议我使用 Google 的 BigQuery 来查看 Firebase 消息传递功能的数据集。

在 Firebase 设置中启用 BigQuery 集成后，您只需转到 BigQuery 控制台即可。

像下面这样的查询将为您提供给定消息的详细信息。

SELECT *
FROM `<project_name>.firebase_messaging.data`
WHERE
   _PARTITIONTIME = TIMESTAMP('<date as YYYY-MM-DD>')
   AND message_id = '<your message id>'
   AND instance_id = '<your instance id>'
ORDER BY event_timestamp;

链接可查看更多示例并了解 FCM 的 BigQuery 集成 => 了解消息传递