แอปที่ใช้ฟังก์ชันรุ่นที่ 1 ควรพิจารณาการย้ายข้อมูลไปยังรุ่นที่ 2 โดยใช้วิธีการในคำแนะนำนี้ ฟังก์ชันรุ่นที่ 2 ใช้ Cloud Run เพื่อให้ ประสิทธิภาพ การกำหนดค่า การตรวจสอบ และอื่นๆ ที่ดียิ่งขึ้น
ตัวอย่างในเอกสารนี้ถือว่าคุณใช้ JavaScript กับโมดูล CommonJS
(การนำเข้าสไตล์ require) แต่หลักการเดียวกันนี้ใช้ได้กับ JavaScript ที่มี ESM
(การนำเข้าสไตล์ import … from) และ TypeScript
กระบวนการย้ายข้อมูล
ฟังก์ชันรุ่นที่ 1 และรุ่นที่ 2 สามารถอยู่ร่วมกันในไฟล์เดียวกันได้ ซึ่งจะช่วยให้คุณย้ายฐานของโค้ดทีละส่วนได้เมื่อพร้อม เราขอแนะนำให้ ย้ายข้อมูลฟังก์ชันทีละรายการ ทำการทดสอบและยืนยันก่อน ดำเนินการต่อ
ยืนยันเวอร์ชันของ Firebase CLI และ firebase-function
ตรวจสอบว่าคุณใช้ Firebase CLI เวอร์ชัน 12.00 และ
firebase-functions เวอร์ชัน 4.3.0 เป็นอย่างน้อย ส่วนเวอร์ชันใหม่กว่าจะรองรับทั้งรุ่นที่ 2 และรุ่นที่ 1
อัปเดตการนำเข้า
ฟังก์ชันรุ่นที่ 2 จะนำเข้าจากแพ็กเกจย่อย v2 ใน SDK firebase-functions
เส้นทางการนำเข้าที่แตกต่างกันนี้คือสิ่งที่ CLI Firebase ต้องการเพื่อพิจารณาว่าจะ
ทำให้โค้ดฟังก์ชันของคุณเป็นฟังก์ชันรุ่นที่ 1 หรือรุ่นที่ 2
v2แพ็กเกจย่อยเป็นแบบแยกส่วน และเราขอแนะนำให้นำเข้าเฉพาะโมดูลที่ต้องการเท่านั้น
ก่อน: รุ่นที่ 1
const functions = require("firebase-functions/v1");
หลัง: รุ่นที่ 2
// explicitly import each trigger
const {onRequest} = require("firebase-functions/v2/https");
const {onDocumentCreated} = require("firebase-functions/v2/firestore");
อัปเดตคำจำกัดความของทริกเกอร์
เนื่องจาก SDK รุ่นที่ 2 จะเน้นการนำเข้าแบบแยกส่วน ให้อัปเดตคำจำกัดความของทริกเกอร์เพื่อ แสดงการนำเข้าที่เปลี่ยนแปลงจากขั้นตอนก่อนหน้า
อาร์กิวเมนต์ที่ส่งไปยังการเรียกกลับสำหรับทริกเกอร์บางรายการมีการเปลี่ยนแปลง ในตัวอย่างนี้ โปรดสังเกตว่าอาร์กิวเมนต์ของแฮนเดิล onDocumentCreated ได้รับการรวมเป็นออบเจ็กต์ event เดียว นอกจากนี้ ทริกเกอร์บางรายการยังมี
ฟีเจอร์การกำหนดค่าใหม่ที่สะดวก เช่น ตัวเลือกonRequestของcors
ทริกเกอร์
ก่อน: รุ่นที่ 1
const functions = require("firebase-functions/v1");
exports.date = functions.https.onRequest((req, res) => {
// ...
});
exports.uppercase = functions.firestore
.document("my-collection/{docId}")
.onCreate((change, context) => {
// ...
});
หลัง: รุ่นที่ 2
const {onRequest} = require("firebase-functions/v2/https");
const {onDocumentCreated} = require("firebase-functions/v2/firestore");
exports.date = onRequest({cors: true}, (req, res) => {
// ...
});
exports.uppercase = onDocumentCreated("my-collection/{docId}", (event) => {
/* ... */
});
ลดความพยายามในการเขียนใหม่ด้วยการแยกโครงสร้าง JavaScript
หากฟังก์ชันมีเนื้อหาที่ซับซ้อนซึ่งต้องอาศัยบริบทรุ่นที่ 1 หรือพารามิเตอร์เฉพาะผู้ให้บริการ (เช่น message หรือ snapshot) เป็นอย่างมาก คุณสามารถใช้ตัวช่วยความเข้ากันได้กับรุ่นที่ 1 ซึ่งมีอยู่ใน SDK รุ่นที่ 2
SDK รุ่นที่ 2 จะแก้ไขออบเจ็กต์เหตุการณ์โดยอัตโนมัติด้วยตัวรับที่ตรงกับลายเซ็นรุ่นที่ 1 ซึ่งช่วยให้คุณใช้การแยกโครงสร้าง JavaScript เพื่อดึงพร็อพเพอร์ตี้เหล่านี้ได้โดยตรงในลายเซ็นของตัวแฮนเดิล ซึ่งจะช่วยลดความจำเป็นในการเขียนตรรกะของฟังก์ชันใหม่
การอ้างอิงการแมปผู้ให้บริการ
| ผู้ให้บริการ | อาร์กิวเมนต์รุ่นที่ 1 | การแยกโครงสร้างเหตุการณ์ที่แก้ไขแล้วรุ่นที่ 2 |
| Pub/Sub | (message, context)
|
({ message, context }) => { ... }
|
| Firestore | (snapshot, context)
|
({ snapshot, context }) => { ... }
|
| พื้นที่เก็บข้อมูล | (object, context)
|
({ object, context }) => { ... }
|
| Realtime Database | (snapshot, context)
|
({ snapshot, context }) => { ... }
|
| การกำหนดค่าระยะไกล | (version, context)
|
({ version, context }) => { ... }
|
| เครื่องจัดตารางเวลา | (context)
|
({ context }) => { ... }
|
| คิวงาน | (data, context)
|
({ data, context }) => { ... }
|
ก่อน (รุ่นที่ 1):
export const myPubSubV1 = functions.pubsub.topic("my-topic").onPublish((message, context) => {
const data = message.json;
const eventId = context.eventId;
// ... rest of the logic
});
ทางเลือกใหม่ (รุ่นที่ 2 ที่มีการแยกโครงสร้าง):
import { onMessagePublished } from "firebase-functions/v2/pubsub";
export const myPubSubV2 = onMessagePublished("my-topic", ({ message, context }) => {
// No need to change the function body!
const data = message.json; // Uses v1 Message wrapper
const eventId = context.eventId; // Uses v1 EventContext map
// ... rest of the logic
});
ใช้การกำหนดค่าแบบพารามิเตอร์
ฟังก์ชันรุ่นที่ 2 จะเลิกการรองรับ functions.config เพื่อให้มีอินเทอร์เฟซที่ปลอดภัยยิ่งขึ้นสำหรับการกำหนดพารามิเตอร์การกำหนดค่าแบบประกาศภายในโค้ดเบส
โมดูล params ใหม่จะบล็อกการติดตั้งใช้งาน CLI เว้นแต่พารามิเตอร์ทั้งหมด
จะมีค่าที่ถูกต้อง เพื่อให้มั่นใจว่าจะไม่มีการติดตั้งใช้งานฟังก์ชันโดยไม่มี
การกำหนดค่า
ก่อน: รุ่นที่ 1
const functions = require("firebase-functions/v1");
exports.getQuote = functions.https.onRequest(async (req, res) => {
const quote = await fetchMotivationalQuote(functions.config().apiKey);
// ...
});
หลัง: รุ่นที่ 2
const {onRequest} = require("firebase-functions/v2/https");
const {defineSecret} = require("firebase-functions/params");
// Define the secret parameter
const apiKey = defineSecret("API_KEY");
exports.getQuote = onRequest(
// make the secret available to this function
{ secrets: [apiKey] },
async (req, res) => {
// retrieve the value of the secret
const quote = await fetchMotivationalQuote(apiKey.value());
// ...
}
);
หากมีการกำหนดค่าสภาพแวดล้อมที่มีอยู่ด้วย functions.config ให้ย้ายข้อมูล
การกำหนดค่านี้เป็นส่วนหนึ่งของการอัปเกรดเป็นรุ่นที่ 2
functions.config API เลิกใช้งานแล้วและจะหยุดให้บริการในเดือนมีนาคม 2027
หลังจากวันที่ดังกล่าว การติดตั้งใช้งานที่มี functions.config จะล้มเหลว
หากต้องการป้องกันไม่ให้การติดตั้งใช้งานล้มเหลว ให้ย้ายข้อมูลการกำหนดค่าไปยัง Cloud Secret Manager โดยใช้ Firebase CLI เราขอแนะนำอย่างยิ่งให้ใช้วิธีนี้เนื่องจากเป็นวิธีที่มีประสิทธิภาพและปลอดภัยที่สุดในการย้ายข้อมูลการกำหนดค่า
ส่งออกการกำหนดค่าด้วย FirebaseCLI
ใช้คำสั่ง
config exportเพื่อส่งออกการกำหนดค่าสภาพแวดล้อมที่มีอยู่ไปยังข้อมูลลับใหม่ใน Cloud Secret Manager$ firebase functions:config:export i This command retrieves your Runtime Config values (accessed via functions.config()) and exports them as a Secret Manager secret. i Fetching your existing functions.config() from your project... ✔ Fetched your existing functions.config(). i Configuration to be exported: ⚠ This may contain sensitive data. Do not share this output. { ... } ✔ What would you like to name the new secret for your configuration? RUNTIME_CONFIG ✔ Created new secret version projects/project/secrets/RUNTIME_CONFIG/versions/1```อัปเดตโค้ดฟังก์ชันเพื่อเชื่อมโยงข้อมูลลับ
หากต้องการใช้การกำหนดค่าที่จัดเก็บไว้ในข้อมูลลับใหม่ใน Cloud Secret Manager ให้ใช้
defineJsonSecretAPI ในแหล่งที่มาของฟังก์ชัน และตรวจสอบว่าได้เชื่อมโยงข้อมูลลับกับฟังก์ชันทั้งหมดที่ต้องการใช้ข้อมูลลับนั้นก่อน
const functions = require("firebase-functions/v1"); exports.myFunction = functions.https.onRequest((req, res) => { const apiKey = functions.config().someapi.key; // ... });หลัง
const { onRequest } = require("firebase-functions/v2/https"); const { defineJsonSecret } = require("firebase-functions/params"); const config = defineJsonSecret("RUNTIME_CONFIG"); exports.myFunction = onRequest( // Bind secret to your function { secrets: [config] }, (req, res) => { // Access secret values via .value() const apiKey = config.value().someapi.key; // ... });ทำให้ฟังก์ชันใช้งานได้
ทำให้ฟังก์ชันที่อัปเดตใช้งานได้เพื่อใช้การเปลี่ยนแปลงและเชื่อมโยงสิทธิ์ของ Secret
firebase deploy --only functions:<your-function-name>
ตั้งค่าตัวเลือกของรันไทม์
การกำหนดค่าตัวเลือกขณะรันไทม์ มีการเปลี่ยนแปลงระหว่างรุ่นที่ 1 กับรุ่นที่ 2 นอกจากนี้ รุ่นที่ 2 ยังเพิ่มความสามารถใหม่ในการ ตั้งค่าตัวเลือกสำหรับฟังก์ชันทั้งหมด
ก่อน: รุ่นที่ 1
const functions = require("firebase-functions/v1");
exports.date = functions
.runWith({
// Keep 5 instances warm for this latency-critical function
minInstances: 5,
})
// locate function closest to users
.region("asia-northeast1")
.https.onRequest((req, res) => {
// ...
});
exports.uppercase = functions
// locate function closest to users and database
.region("asia-northeast1")
.firestore.document("my-collection/{docId}")
.onCreate((change, context) => {
// ...
});
หลัง: รุ่นที่ 2
const {onRequest} = require("firebase-functions/v2/https");
const {onDocumentCreated} = require("firebase-functions/v2/firestore");
const {setGlobalOptions} = require("firebase-functions/v2");
// locate all functions closest to users
setGlobalOptions({ region: "asia-northeast1" });
exports.date = onRequest({
// Keep 5 instances warm for this latency-critical function
minInstances: 5,
}, (req, res) => {
// ...
});
exports.uppercase = onDocumentCreated("my-collection/{docId}", (event) => {
/* ... */
});
อัปเดตบัญชีบริการเริ่มต้น (ไม่บังคับ)
แม้ว่าฟังก์ชันรุ่นที่ 1 จะใช้บัญชีบริการเริ่มต้นของ Google App Engine เพื่อให้สิทธิ์เข้าถึง Firebase API แต่ฟังก์ชันรุ่นที่ 2 จะใช้บัญชีบริการเริ่มต้นของ Compute Engine ความแตกต่างนี้อาจทำให้เกิดปัญหาเกี่ยวกับสิทธิ์สำหรับฟังก์ชันที่ย้ายข้อมูลไปยังรุ่นที่ 2 ในกรณีที่คุณได้ให้สิทธิ์พิเศษแก่บัญชีบริการรุ่นที่ 1 หากคุณไม่ได้เปลี่ยนแปลงสิทธิ์ของบัญชีบริการใดๆ คุณสามารถข้ามขั้นตอนนี้ได้
โซลูชันที่แนะนำคือการกำหนดบัญชีบริการเริ่มต้นของ App Engine รุ่นที่ 1 ที่มีอยู่ให้กับฟังก์ชันที่คุณต้องการย้ายข้อมูลไปยังรุ่นที่ 2 อย่างชัดเจน
โดยลบล้างค่าเริ่มต้นของรุ่นที่ 2 คุณทำได้โดยตรวจสอบว่าฟังก์ชันที่ย้ายข้อมูลแต่ละรายการ
กำหนดค่าที่ถูกต้องสำหรับ serviceAccountEmail ดังนี้
const {onRequest} = require("firebase-functions/https");
const {onDocumentCreated} = require("firebase-functions/v2/firestore");
const {setGlobalOptions} = require("firebase-functions");
// Use the App Engine default service account for all functions
setGlobalOptions({serviceAccountEmail: '<my-project-number>@<wbr>appspot.gserviceaccount.com'});
// Now I use the App Engine default service account.
exports.date = onRequest({cors: true}, (req, res) => {
// ...
});
// I do too!
exports.uppercase = onDocumentCreated("my-collection/{docId}", (event) => {
// ...
});
หรือคุณอาจแก้ไขรายละเอียดบัญชีบริการให้ตรงกับสิทธิ์ที่จำเป็นทั้งหมดในทั้งบัญชีบริการเริ่มต้นของ App Engine (สำหรับรุ่นที่ 1) และบัญชีบริการเริ่มต้นของ Compute Engine (สำหรับรุ่นที่ 2)
ใช้การทำงานพร้อมกัน
ข้อได้เปรียบที่สำคัญของฟังก์ชันรุ่นที่ 2 คือความสามารถของอินสแตนซ์ฟังก์ชันเดียวในการให้บริการคำขอมากกว่า 1 รายการพร้อมกัน ซึ่งจะช่วยลดจำนวน Cold Start ที่ผู้ใช้ปลายทางพบได้อย่างมาก โดยค่าเริ่มต้น ระบบจะตั้งค่าการทำงานพร้อมกันไว้ที่ 80 แต่คุณสามารถตั้งค่าเป็นค่าใดก็ได้ตั้งแต่ 1 ถึง 1,000
const {onRequest} = require("firebase-functions/v2/https");
exports.date = onRequest({
// set concurrency value
concurrency: 500
},
(req, res) => {
// ...
});
การปรับแต่งการทำงานพร้อมกันจะช่วยปรับปรุงประสิทธิภาพและลดต้นทุนของฟังก์ชันได้ ดูข้อมูลเพิ่มเติมเกี่ยวกับการเกิดขึ้นพร้อมกันได้ที่อนุญาตคำขอหลายรายการพร้อมกัน
ตรวจสอบการใช้ตัวแปรส่วนกลาง
ฟังก์ชันรุ่นที่ 1 ที่เขียนโดยไม่ได้คำนึงถึงการทำงานพร้อมกันอาจใช้ตัวแปรส่วนกลาง ที่ตั้งค่าและอ่านในแต่ละคำขอ เมื่อเปิดใช้การทำงานพร้อมกันและอินสแตนซ์เดียว เริ่มจัดการคำขอหลายรายการพร้อมกัน อาจทำให้เกิดข้อบกพร่องใน ฟังก์ชันเนื่องจากคำขอที่ทำงานพร้อมกันเริ่มตั้งค่าและอ่านตัวแปรส่วนกลาง พร้อมกัน
ขณะอัปเกรด คุณสามารถตั้งค่า CPU ของฟังก์ชันเป็น gcf_gen1 และตั้งค่า
concurrency เป็น 1 เพื่อคืนค่าลักษณะการทำงานของรุ่นที่ 1 ได้โดยทำดังนี้
const {onRequest} = require("firebase-functions/v2/https");
exports.date = onRequest({
// TEMPORARY FIX: remove concurrency
cpu: "gcf_gen1",
concurrency: 1
},
(req, res) => {
// ...
});
อย่างไรก็ตาม เราไม่แนะนำให้ใช้วิธีนี้เป็นการแก้ไขระยะยาว เนื่องจากจะทำให้เสียข้อได้เปรียบด้านประสิทธิภาพของฟังก์ชันรุ่นที่ 2 แต่ให้ตรวจสอบการใช้ตัวแปรส่วนกลางในฟังก์ชัน และนำการตั้งค่าชั่วคราวเหล่านี้ออกเมื่อพร้อม
ย้ายการรับส่งข้อมูลไปยังฟังก์ชันรุ่นที่ 2 ใหม่
เช่นเดียวกับเมื่อเปลี่ยนภูมิภาคหรือประเภททริกเกอร์ของฟังก์ชัน คุณจะต้องตั้งชื่อใหม่ให้กับฟังก์ชันรุ่นที่ 2 และค่อยๆ ย้ายข้อมูล ไปยังฟังก์ชันดังกล่าว
คุณไม่สามารถอัปเกรดฟังก์ชันจากรุ่นที่ 1 เป็นรุ่นที่ 2 โดยใช้ชื่อเดียวกัน
และเรียกใช้ firebase deploy ได้ การดำเนินการดังกล่าวจะทำให้เกิดข้อผิดพลาดต่อไปนี้
Upgrading from GCFv1 to GCFv2 is not yet supported. Please delete your old function or wait for this feature to be ready.
กลยุทธ์การย้ายข้อมูลจะขึ้นอยู่กับประเภททริกเกอร์ที่ฟังก์ชันใช้
สำหรับทริกเกอร์ที่เรียกใช้ได้ คิวงาน และ HTTP
ทริกเกอร์เหล่านี้เป็นการเรียกใช้โดยตรง เนื่องจากฟังก์ชันรุ่นที่ 2 จะมีชื่อใหม่ (และ URL ใหม่สำหรับทริกเกอร์ HTTP) คุณจึงย้ายข้อมูลการเข้าชมได้โดยการอัปเดตไคลเอ็นต์
- เปลี่ยนชื่อฟังก์ชันในโค้ด (เช่น เปลี่ยนชื่อ
myCallableเป็นmyCallableV2) - ทําให้ฟังก์ชันใช้งานได้ ตอนนี้ฟังก์ชันทั้งรุ่นที่ 1 และรุ่นที่ 2 ทํางานแล้ว
- อัปเดตโค้ดไคลเอ็นต์หรือผู้โทรให้ชี้ไปยังชื่อหรือ URL ของฟังก์ชันรุ่นที่ 2 ใหม่
- เมื่อการรับส่งข้อมูลทั้งหมดเปลี่ยนไปใช้ฟังก์ชันใหม่แล้ว ให้ลบฟังก์ชันรุ่นที่ 1 โดยใช้คำสั่ง
firebase functions:deleteของ Firebase CLI
สำหรับทริกเกอร์ในเบื้องหลัง (Pub/Sub, Cloud Firestore, Cloud Storage ฯลฯ)
ทริกเกอร์ในเบื้องหลังจะตอบสนองต่อเหตุการณ์ในโปรเจ็กต์ของคุณ เพื่อไม่ให้พลาดเหตุการณ์ใดๆ ในระหว่างการเปลี่ยนผ่าน คุณต้องเรียกใช้ฟังก์ชันรุ่นที่ 1 และรุ่นที่ 2 ควบคู่กันชั่วคราว
ในระหว่างช่วงการเปลี่ยนผ่าน ฟังก์ชันทั้ง 2 จะทริกเกอร์ในเหตุการณ์เดียวกัน ซึ่งหมายความว่าตรรกะทางธุรกิจจะทํางาน 2 ครั้งต่อเหตุการณ์ โปรดตรวจสอบว่าฟังก์ชัน เป็นไอดีมโพเทนต์ ก่อนดําเนินการต่อ
ขั้นตอนที่ 1: เพิ่มฟังก์ชันรุ่นที่ 2 ควบคู่ไปกับฟังก์ชันรุ่นที่ 1
เก็บฟังก์ชันรุ่นที่ 1 ที่มีอยู่ไว้ในโค้ด แล้วเพิ่มฟังก์ชันรุ่นที่ 2 ที่รับฟังแหล่งที่มาของเหตุการณ์เดียวกัน
เคล็ดลับสำหรับมือโปร: ใช้การส่งต่อเพื่อการยืนยัน
หากต้องการหลีกเลี่ยงการทำซ้ำตรรกะทางธุรกิจในฐานของโค้ดระหว่างการเปลี่ยนผ่าน
หรือเพื่อยืนยันว่าฟังก์ชันรุ่นที่ 2 ได้รับเหตุการณ์อย่างถูกต้องก่อน
ที่จะเชื่อถืออย่างเต็มที่ ให้กำหนดฟังก์ชันรุ่นที่ 2 เป็นการส่งต่อที่เรียกฟังก์ชันรุ่นที่ 1 โดยใช้วิธี run
import * as functions from "firebase-functions/v1";
import { onMessagePublished } from "firebase-functions/v2/pubsub";
// --- Existing 1st gen function ---
export const myPubSub = functions.pubsub.topic("my-topic").onPublish((message, context) => {
console.log("V1 handler running for event:", context.eventId);
// ... existing v1 function logic ...
});
// --- New v2 passthrough function ---
export const myPubSubV2 = onMessagePublished("my-topic", async ({ message, context }) => {
console.log("v2 handler triggering V1 for event:", context.eventId);
// Call the v1 function's handler
await myPubSub.run(message, context);
});
ขั้นตอนที่ 2: ทำให้ฟังก์ชันทั้ง 2 ใช้งานได้
เรียกใช้ firebase deploy ตอนนี้ฟังก์ชันทั้ง 2 จะทำงานและรอรับฟังเหตุการณ์เดียวกัน
ขั้นตอนที่ 3: ยืนยันว่าฟังก์ชันรุ่นที่ 2 ได้รับการเข้าชม
ตรวจสอบบันทึกของทั้ง 2 ฟังก์ชัน ตรวจสอบว่ามีการเรียกใช้ฟังก์ชันรุ่นที่ 2 สำหรับเหตุการณ์ทั้งหมดและเรียกใช้ได้สำเร็จ
ขั้นตอนที่ 4: ย้ายตรรกะทั้งหมดไปยังฟังก์ชันรุ่นที่ 2
เมื่อมั่นใจแล้ว ให้ย้ายตรรกะทางธุรกิจจริงจากฟังก์ชันรุ่นที่ 1 ไปยังเนื้อหาของฟังก์ชันรุ่นที่ 2 หากคุณใช้วิธีส่งผ่าน ให้นำการเรียกไปยัง myPubSub.run() ออก
import * as functions from "firebase-functions/v1";
import { onMessagePublished } from "firebase-functions/v2/pubsub";
// --- Existing v1 function (to be removed next) ---
export const myPubSub = functions.pubsub.topic("my-topic").onPublish((message, context) => {
console.log("v1 handler running for event:", context.eventId);
// ... existing v1 function logic ...
});
// --- New v2 function with full logic ---
export const myPubSubV2 = onMessagePublished("my-topic", ({ message, context }) => {
console.log("v2 handler running for event:", context.eventId);
// ... existing v1 function logic WAS MOVED HERE ...
});
ใช้การเปลี่ยนแปลงนี้
ขั้นตอนที่ 5: เลิกใช้งานฟังก์ชันรุ่นที่ 1
นำคำจำกัดความของฟังก์ชันรุ่นที่ 1 ออกจากโค้ดแล้วทำการติดตั้งใช้งานอีกครั้ง CLI จะ แจ้งให้คุณลบฟังก์ชันรุ่นที่ 1 ออกจาก Google Cloud
import { onMessagePublished } from "firebase-functions/v2/pubsub";
// --- V1 function definition REMOVED ---
// --- New v2 function with full logic ---
export const myPubSubV2 = onMessagePublished("my-topic", ({ message, context }) => {
console.log("v2 handler running for event:", context.eventId);
// ... existing v1 function logic ...
});