Google Cloud'un Pub/Sub hizmeti, ihtiyaç duyduğunuzda otomatik olarak ölçeklendirilen ve küresel olarak dağıtılan bir mesaj yoludur. functions.pubsub
kullanarak Pub/Sub etkinliklerini işleyen bir işlev oluşturabilirsiniz.
Pub/Sub işlevini tetikleme
Belirli bir konuya yeni bir Pub/Sub mesajı gönderildiğinde bir işlevi tetikleyebilirsiniz. İşlevinizi tetiklemesini istediğiniz Pub/Sub konu adını belirtmeniz ve etkinliği onPublish()
etkinlik işleyici içinde ayarlamanız gerekir:
exports.helloPubSub = functions.pubsub.topic('topic-name').onPublish((message) => { // ... });
Pub/Sub mesaj yüküne {:#access-pub/sub} erişin
Pub/Sub mesajının yüküne, işlevinize döndürülen Message
nesnesinden erişilebilir. Pub/Sub mesaj gövdesinde JSON içeren mesajlar için Cloud Functions için Firebase SDK'sı, mesajın kodunu çözmek üzere yardımcı bir özelliğe sahiptir. Örneğin, burada basit bir JSON yüküyle yayınlanan bir mesajı görebilirsiniz:
gcloud pubsub topics publish topic-name --message '{"name":"Xenia"}'
Şuna benzer bir JSON veri yüküne json
özelliği aracılığıyla erişebilirsiniz:
// Get the `name` attribute of the PubSub message JSON body. let name = null; try { name = message.json.name; } catch (e) { functions.logger.error('PubSub message was not JSON', e); }
Diğer JSON dışı yükler, Pub/Sub mesajının mesaj nesnesinde base64 olarak kodlanmış dizeler halinde yer alır. Aşağıdaki gibi bir mesajı okumak için base64 kodlu dizenin kodunu aşağıda gösterildiği gibi çözmeniz gerekir:
gcloud pubsub topics publish topic-name --message 'MyMessage'
// Decode the PubSub Message body. const messageBody = message.data ? Buffer.from(message.data, 'base64').toString() : null;
{:#access-message} etkinliklerinin mesaj özelliklerine erişme
Pub/Sub mesajı, "publish" komutunda belirlenen veri özellikleriyle gönderilebilir. Örneğin, name
özelliğine sahip bir mesaj yayınlayabilirsiniz:
gcloud pubsub topics publish topic-name --attribute name=Xenia
Bu tür özellikleri Message.attributes
'ten okuyabilirsiniz:
// Get the `name` attribute of the message. const name = message.attributes.name;
Mesaj kimliği veya mesaj yayınlanma zamanı gibi bazı temel verilerin Message.attributes
ürününde kullanılamadığını fark edebilirsiniz. Bu sorunu çözmek için tetikleyici etkinliğin EventContext
bölümünden bu ayrıntılara erişebilirsiniz.
Örnek:
exports.myFunction = functions.pubsub.topic('topic1').onPublish((message, context) => {
console.log('The function was triggered at ', context.timestamp);
console.log('The unique ID for the event is', context.eventId);
});