Điều kiện kích hoạt Cơ sở dữ liệu theo thời gian thực

Với Cloud Functions, bạn có thể xử lý các sự kiện trong Cơ sở dữ liệu theo thời gian thực của Firebase mà không cần cập nhật mã ứng dụng. Cloud Functions cho phép bạn chạy các hoạt động của Cơ sở dữ liệu theo thời gian thực với đầy đủ các đặc quyền quản trị và đảm bảo rằng mỗi thay đổi đối với Cơ sở dữ liệu theo thời gian thực đều được xử lý riêng. Bạn có thể thực hiện các thay đổi đối với Cơ sở dữ liệu theo thời gian thực của Firebase thông qua DataSnapshot hoặc thông qua SDK quản trị.

Trong một vòng đời thông thường, chức năng của Cơ sở dữ liệu theo thời gian thực của Firebase thực hiện những việc sau:

Chờ những thay đổi đối với một vị trí cụ thể của Cơ sở dữ liệu theo thời gian thực.
Kích hoạt khi một sự kiện xảy ra và thực hiện các nhiệm vụ của sự kiện đó (xem bài viết Tôi có thể làm gì với Cloud Functions? để biết ví dụ về các trường hợp sử dụng).
Nhận một đối tượng dữ liệu chứa ảnh chụp nhanh về dữ liệu được lưu trữ trong tài liệu được chỉ định.

Kích hoạt hàm Cơ sở dữ liệu theo thời gian thực

Tạo hàm mới cho các sự kiện trong Cơ sở dữ liệu theo thời gian thực bằng functions.database. Để kiểm soát thời điểm hàm kích hoạt, hãy chỉ định một trong các trình xử lý sự kiện và chỉ định đường dẫn Cơ sở dữ liệu theo thời gian thực để theo dõi các sự kiện.

Thiết lập trình xử lý sự kiện

Các hàm cho phép bạn xử lý các sự kiện trong Cơ sở dữ liệu theo thời gian thực ở hai cấp độ cụ thể; bạn chỉ có thể theo dõi các sự kiện tạo, cập nhật hoặc xoá hoặc bạn có thể theo dõi mọi thay đổi ở bất kỳ loại đường dẫn nào. Cloud Functions hỗ trợ các trình xử lý sự kiện sau đây cho Cơ sở dữ liệu theo thời gian thực:

onWrite(): sẽ kích hoạt khi dữ liệu được tạo, cập nhật hoặc xoá trong Cơ sở dữ liệu theo thời gian thực.
onCreate(): kích hoạt khi dữ liệu mới được tạo trong Cơ sở dữ liệu theo thời gian thực.
onUpdate(), kích hoạt khi dữ liệu được cập nhật trong Cơ sở dữ liệu theo thời gian thực .
onDelete(): sẽ kích hoạt khi dữ liệu bị xoá khỏi Cơ sở dữ liệu theo thời gian thực .

Chỉ định thực thể và đường dẫn

Để kiểm soát thời điểm và vị trí mà hàm của bạn sẽ kích hoạt, hãy gọi ref(path) để chỉ định một đường dẫn và tuỳ ý chỉ định một thực thể Cơ sở dữ liệu theo thời gian thực bằng instance('INSTANCE_NAME'). Nếu bạn không chỉ định phiên bản, hàm sẽ triển khai cho phiên bản Cơ sở dữ liệu theo thời gian thực mặc định cho dự án Firebase. Ví dụ:

Phiên bản Cơ sở dữ liệu theo thời gian thực mặc định: functions.database.ref('/foo/bar')
Thực thể có tên là "my-app-db-2": functions.database.instance('my-app-db-2').ref('/foo/bar')

Các phương thức này chỉ dẫn hàm của bạn xử lý các lượt ghi tại một đường dẫn nhất định trong thực thể của Cơ sở dữ liệu theo thời gian thực. Thông số kỹ thuật của đường dẫn khớp với tất cả các lượt ghi chạm vào một đường dẫn, bao gồm cả các lượt ghi xảy ra ở bất kỳ vị trí nào bên dưới đường dẫn đó. Nếu bạn đặt đường dẫn cho hàm là /foo/bar, đường dẫn này sẽ khớp với các sự kiện ở cả hai vị trí sau:

 /foo/bar
 /foo/bar/baz/really/deep/path

Trong cả hai trường hợp, Firebase diễn giải rằng sự kiện xảy ra tại /foo/bar và dữ liệu sự kiện bao gồm dữ liệu cũ và mới tại /foo/bar. Nếu dữ liệu sự kiện có thể lớn, hãy cân nhắc sử dụng nhiều hàm ở các đường dẫn sâu hơn thay vì một hàm duy nhất gần gốc của cơ sở dữ liệu. Để đạt được hiệu suất tốt nhất, chỉ yêu cầu dữ liệu ở cấp sâu nhất có thể.

Bạn có thể chỉ định một thành phần đường dẫn làm ký tự đại diện bằng cách đặt thành phần đó trong dấu ngoặc nhọn; ref('foo/{bar}') khớp với mọi thành phần con của /foo. Giá trị của các thành phần đường dẫn thẻ ký tự đại diện này có sẵn trong đối tượng EventContext.params của hàm. Trong ví dụ này, giá trị được cung cấp dưới dạng context.params.bar.

Đường dẫn chứa ký tự đại diện có thể khớp với nhiều sự kiện từ một lần ghi. Phụ trang của

{
  "foo": {
    "hello": "world",
    "firebase": "functions"
  }
}

khớp với đường dẫn "/foo/{bar}" hai lần: một lần với "hello": "world" và một lần nữa với "firebase": "functions".

Xử lý dữ liệu sự kiện

Khi xử lý sự kiện Cơ sở dữ liệu theo thời gian thực, đối tượng dữ liệu được trả về là DataSnapshot. Đối với các sự kiện onWrite hoặc onUpdate, tham số đầu tiên là đối tượng Change chứa hai bản tổng quan nhanh thể hiện trạng thái dữ liệu trước và sau sự kiện kích hoạt. Đối với các sự kiện onCreate và onDelete, đối tượng dữ liệu được trả về là thông tin tổng quan nhanh về dữ liệu được tạo hoặc xoá.

Trong ví dụ này, hàm truy xuất bản tổng quan nhanh cho đường dẫn được chỉ định, chuyển đổi chuỗi tại vị trí đó thành chữ hoa và ghi chuỗi đã sửa đổi vào cơ sở dữ liệu:

// Listens for new messages added to /messages/:pushId/original and creates an
// uppercase version of the message to /messages/:pushId/uppercase
exports.makeUppercase = functions.database.ref('/messages/{pushId}/original')
    .onCreate((snapshot, context) => {
      // Grab the current value of what was written to the Realtime Database.
      const original = snapshot.val();
      functions.logger.log('Uppercasing', context.params.pushId, original);
      const uppercase = original.toUpperCase();
      // You must return a Promise when performing asynchronous tasks inside a Functions such as
      // writing to the Firebase Realtime Database.
      // Setting an "uppercase" sibling in the Realtime Database returns a Promise.
      return snapshot.ref.parent.child('uppercase').set(uppercase);
    });index.js

Truy cập thông tin xác thực người dùng

Từ EventContext.auth và EventContext.authType, bạn có thể truy cập vào thông tin người dùng, bao gồm cả các quyền, đối với người dùng đã kích hoạt một hàm. Điều này có thể hữu ích cho việc thực thi các quy tắc bảo mật, cho phép hàm của bạn hoàn tất các thao tác khác nhau dựa trên cấp độ quyền của người dùng:

const functions = require('firebase-functions');
const admin = require('firebase-admin');

exports.simpleDbFunction = functions.database.ref('/path')
    .onCreate((snap, context) => {
      if (context.authType === 'ADMIN') {
        // do something
      } else if (context.authType === 'USER') {
        console.log(snap.val(), 'written by', context.auth.uid);
      }
    });

Ngoài ra, bạn có thể tận dụng thông tin xác thực người dùng để "mạo danh" người dùng và thay mặt họ thực hiện các thao tác ghi. Hãy nhớ xoá phiên bản ứng dụng như trình bày dưới đây để ngăn các vấn đề xảy ra đồng thời:

exports.impersonateMakeUpperCase = functions.database.ref('/messages/{pushId}/original')
    .onCreate((snap, context) => {
      const appOptions = JSON.parse(process.env.FIREBASE_CONFIG);
      appOptions.databaseAuthVariableOverride = context.auth;
      const app = admin.initializeApp(appOptions, 'app');
      const uppercase = snap.val().toUpperCase();
      const ref = snap.ref.parent.child('uppercase');

      const deleteApp = () => app.delete().catch(() => null);

      return app.database().ref(ref).set(uppercase).then(res => {
        // Deleting the app is necessary for preventing concurrency leaks
        return deleteApp().then(() => res);
      }).catch(err => {
        return deleteApp().then(() => Promise.reject(err));
      });
    });

Đọc giá trị trước

Đối tượng Change có thuộc tính before cho phép bạn kiểm tra nội dung đã lưu vào Cơ sở dữ liệu theo thời gian thực trước sự kiện đó. Thuộc tính before trả về DataSnapshot, trong đó tất cả phương thức (ví dụ: val() và exists()) đều tham chiếu đến giá trị trước đó. Bạn có thể đọc lại giá trị mới bằng cách sử dụng DataSnapshot ban đầu hoặc đọc thuộc tính after. Thuộc tính này trên bất kỳ Change nào cũng là một DataSnapshot khác thể hiện trạng thái của dữ liệu sau khi sự kiện xảy ra.

Ví dụ: bạn có thể sử dụng thuộc tính before để đảm bảo hàm chỉ viết hoa trong lần tạo đầu tiên:

exports.makeUppercase = functions.database.ref('/messages/{pushId}/original')
    .onWrite((change, context) => {
      // Only edit data when it is first created.
      if (change.before.exists()) {
        return null;
      }
      // Exit when the data is deleted.
      if (!change.after.exists()) {
        return null;
      }
      // Grab the current value of what was written to the Realtime Database.
      const original = change.after.val();
      console.log('Uppercasing', context.params.pushId, original);
      const uppercase = original.toUpperCase();
      // You must return a Promise when performing asynchronous tasks inside a Functions such as
      // writing to the Firebase Realtime Database.
      // Setting an "uppercase" sibling in the Realtime Database returns a Promise.
      return change.after.ref.parent.child('uppercase').set(uppercase);
    });