Lắng nghe cơ sở dữ liệu Firebase trong AWS Lambda lần

Question

Tôi đang xây dựng một kỹ năng Alexa, yêu cầu tôi phải nghe Cơ sở dữ liệu thời gian thực Firebase. Trong một phần cụ thể của kỹ năng, tôi cần phải viết một đối tượng JSON vào Firebase, bao gồm hai trường, "ý định", với một giá trị không đáng kể và "đã hoàn thành", với giá trị là false. Sau đó, tôi đợi một thiết bị khác nghe cơ sở dữ liệu này để đăng ký thay đổi này, tại thời điểm đó nó tạo ra một trường khác, có tên là "kết quả", với một số giá trị số và thay đổi giá trị "đã hoàn thành" thành true.

Sau đó, chức năng gốc (test1) phải nhận ra khi giá trị "thực hiện" là đúng và sau đó truy xuất giá trị của "kết quả".

Điều tôi đang gặp phải là có chức năng thực hiện tất cả các thao tác đọc/ghi này trước khi chức năng chính (không đồng bộ) của tôi kết thúc. Như tiêu đề cho thấy, AWS Lambda lần vì lý do nào đó, và tôi không thể đọc giá trị của "kết quả".

Đây là chức năng Tôi đang sử dụng:

function test1(intentName, targetRef, context) { 
    console.log("writing"); 
    targetRef.set({ 
     intent: intentName, 
     done: false 
    }).then(function() { 
     return targetRef.orderByChild("done").equalTo(true).on("value"); 
    }).then(function(snapshot) { 
     var res = snapshot.val().result; 
     console.log("Res: " + res); 
     context.succeed(//context.succeed should be called after "result" has a value. 
      generateResponse(
       buildSpeechletReponse("The result is" + processNumbersForSpeech(res), true), 
       {} 
      ) 
     ); 
    }); 
} 

Đây là sản phẩm của giao diện điều khiển (trong AWS Lambda):

 
20:05:31 
START RequestId: a25d2354-d9cb-11e6-b80a-f35142a5f45f Version: $LATEST 
20:05:31 
2017-01-13T20:05:31.464Z a25d2354-d9cb-11e6-b80a-f35142a5f45f writing 
 
20:05:35 
END RequestId: a25d2354-d9cb-11e6-b80a-f35142a5f45f 
 
20:05:35 
REPORT RequestId: a25d2354-d9cb-11e6-b80a-f35142a5f45f Duration: 4001.15 ms Billed Duration: 4000 ms Memory Size: 128 MB Max Memory Used: 39 MB 
 
20:05:35 
2017-01-13T20:05:35.335Z a25d2354-d9cb-11e6-b80a-f35142a5f45f Task timed out after 4.00 seconds 

Sau đây là cấu trúc của dữ liệu căn cứ hỏa lực:

"thực hiện" ban đầu là sai. Khi thiết bị kia thêm "kết quả", nó cũng cập nhật giá trị "thực hiện" thành true. "148434459 ..." là targetRef.

Trợ giúp của bạn thực sự được đánh giá cao. Tôi sẽ cung cấp thêm thông tin nếu cần.

Answer 1

Hàm lambda của bạn có thể hết sau 4 giây vì bạn đặt giá trị này khi định cấu hình hàm Lambda. Để cho hàm của bạn chờ đợi điều bên ngoài xảy ra, bạn có thể lên lịch một hàm để truy vấn giá trị thường xuyên với setTimeout() cho đến khi giá trị ở đó. Nếu mất hơn 4 giây, bạn cũng cần phải tăng thời gian chờ của chức năng.

Answer 2

Vấn đề là on không trả lại lời hứa. Thay vào đó, nó trả về hàm gọi lại đã được chuyển thành tham số. on sẽ gọi lại cuộc gọi lại cho dữ liệu ban đầu và sau đó lại cho bất kỳ thay đổi nào được thực hiện cho dữ liệu.

Bạn rất có thể muốn sử dụng once, mà trả về một lời hứa:

... 
}).then(function() { 
    return targetRef.orderByChild("done").equalTo(true).once("value"); 
}).then(function (snapshot) { 
    snapshot.forEach(function (childSnapshot) { 
     console.log(childSnapshot.val()); 
    }); 
}) 
... 

Lưu ý rằng ảnh chụp giải quyết của lời hứa sẽ chứa số không hay nhiều trẻ em phù hợp với truy vấn. Để liệt kê các trẻ em, bạn có thể sử dụng phương thức forEach của ảnh chụp nhanh.

Answer 3

Từ các tài liệu AWS Lambda:

Q: bao lâu có thể một chức năng AWS Lambda thực hiện?

Tất cả các cuộc gọi đến AWS Lambda phải hoàn tất việc thực hiện trong vòng 300 giây.Thời gian chờ mặc định là 3 giây, nhưng bạn có thể đặt thời gian chờ thành bất kỳ giá trị nào trong khoảng từ 1 đến 300 giây.

Tôi khuyên bạn nên gặp sự cố khi cố đợi sự kiện Firebase từ bên trong hàm Lambda. Lambda được thiết kế để được gọi với dữ liệu và xử lý dữ liệu và thoát ra, không phải chờ đợi cho các sự kiện khác xảy ra. Bạn nên sử dụng một số loại VPS và chạy một quy trình Node chung để thực hiện công việc cơ sở dữ liệu. Lambda đẩy dữ liệu vào Firebase là tốt, nhưng những gì bạn đang cố gắng đạt được với Firebase có thể là phương pháp sai.

Answer 4

Bạn đang gọi hàm trước khi chức năng khác được gọi. Hãy thử npm sleep() hoặc setTimeout() để tạm dừng chức năng của bạn.

Answer 5

Tôi phát hiện ra cách khởi tạo Firebase trong hàm lambda (ví dụ: thông qua firebase-admin) sẽ ngăn chức năng chấm dứt (cho đến thời gian chờ 6 giây mặc định) trừ khi bạn gọi app.delete() trên phiên bản ứng dụng firebase. Ngoài ra, bạn nên đảm bảo rằng mỗi lần chạy hàm lambda của bạn, bạn đang sử dụng một cá thể ứng dụng firebase mới nếu không bạn sẽ gặp phải sự cố.

const app = admin.initializeApp({}); 
app.database().ref('child').set('hello').then(() => { 
    return app.delete(); 
}).then(() => { 
    let response = {}; // whatever 
    callback(null, response); 
});