ความเรียบง่ายของ Cloud Functions ช่วยให้คุณพัฒนาโค้ดและเรียกใช้โค้ดในสภาพแวดล้อมแบบ Serverless ได้อย่างรวดเร็ว ค่าใช้จ่ายในการเรียกใช้ฟังก์ชันในระดับปานกลางจะต่ำ และการเพิ่มประสิทธิภาพโค้ดอาจไม่ใช่ลำดับความสำคัญสูง อย่างไรก็ตาม เมื่อการทำให้ใช้งานได้ในวงกว้างขึ้น การเพิ่มประสิทธิภาพโค้ดจึงมีความสำคัญเพิ่มมากขึ้นตามไปด้วย
เอกสารนี้จะอธิบายวิธีเพิ่มประสิทธิภาพเครือข่ายสำหรับฟังก์ชันของคุณ ประโยชน์บางส่วนของการเพิ่มประสิทธิภาพเครือข่ายมีดังนี้
- ลดเวลา CPU ที่ใช้ในการสร้างการเชื่อมต่อใหม่ในการเรียกใช้ฟังก์ชันแต่ละครั้ง
- ลดโอกาสที่โควต้า DNS หรือการเชื่อมต่อจะหมด
รักษาการเชื่อมต่อให้คงอยู่ตลอด
ส่วนนี้จะแสดงตัวอย่างวิธีรักษาการเชื่อมต่อถาวรในฟังก์ชัน ไม่เช่นนั้น อาจทำให้โควต้าการเชื่อมต่อหมดอย่างรวดเร็ว
สถานการณ์ในส่วนนี้ครอบคลุมสถานการณ์ต่อไปนี้
- HTTP/S
- Google APIs
คำขอ HTTP/S
ข้อมูลโค้ดที่เพิ่มประสิทธิภาพด้านล่างแสดงวิธีรักษาการเชื่อมต่อถาวรแทนการสร้างการเชื่อมต่อใหม่ทุกครั้งที่เรียกใช้ฟังก์ชัน ดังนี้
Node.js
const http = require('http'); const functions = require('firebase-functions'); // Setting the `keepAlive` option to `true` keeps // connections open between function invocations const agent = new http.Agent({keepAlive: true}); exports.function = functions.https.onRequest((request, response) => { req = http.request({ host: '', port: 80, path: ' ', method: 'GET', agent: agent, // Holds the connection open after the first invocation }, res => { let rawData = ''; res.setEncoding('utf8'); res.on('data', chunk => { rawData += chunk; }); res.on('end', () => { response.status(200).send(`Data: ${rawData}`); }); }); req.on('error', e => { response.status(500).send(`Error: ${e.message}`); }); req.end(); });
Python
from firebase_functions import https_fn import requests # Create a global HTTP session (which provides connection pooling) session = requests.Session() @https_fn.on_request() def connection_pooling(request): # The URL to send the request to url = "http://example.com" # Process the request response = session.get(url) response.raise_for_status() return https_fn.Response("Success!")
ฟังก์ชัน HTTP นี้ใช้พูลการเชื่อมต่อเพื่อสร้างคำขอ HTTP
ซึ่งจะใช้ออบเจ็กต์คำขอ (flask.Request
) และแสดงผลข้อความตอบกลับ หรือชุดค่าที่เปลี่ยนเป็นออบเจ็กต์ Response
ได้โดยใช้ make_response
การเข้าถึง Google API
ตัวอย่างด้านล่างใช้ Cloud Pub/Sub แต่วิธีนี้ยังใช้ได้กับไลบรารีไคลเอ็นต์อื่นๆ ด้วย เช่น Cloud Natural Language หรือ Cloud Spanner โปรดทราบว่าการปรับปรุงประสิทธิภาพอาจขึ้นอยู่กับการใช้งานไลบรารีไคลเอ็นต์ในปัจจุบัน
การสร้างออบเจ็กต์ไคลเอ็นต์ Pub/Sub จะทำให้เกิดการเชื่อมต่อ 1 รายการและมีคำขอ DNS 2 รายการต่อการเรียกใช้ หากต้องการหลีกเลี่ยงการเชื่อมต่อและการค้นหา DNS ที่ไม่จำเป็น ให้สร้างออบเจ็กต์ไคลเอ็นต์ Pub/Sub ในขอบเขตรวมดังที่แสดงในตัวอย่างด้านล่าง
Node.js
const PubSub = require('@google-cloud/pubsub'); const functions = require('firebase-functions'); const pubsub = PubSub(); exports.function = functions.https.onRequest((req, res) => { const topic = pubsub.topic(''); topic.publish('Test message', err => { if (err) { res.status(500).send(`Error publishing the message: ${err}`); } else { res.status(200).send('1 message published'); } }); });
Python
import os from firebase_functions import https_fn from google.cloud import pubsub_v1 # from firebase_functions import https_fn # Create a global Pub/Sub client to avoid unneeded network activity pubsub = pubsub_v1.PublisherClient() @https_fn.on_request() def gcp_api_call(request): project = os.getenv("GCP_PROJECT") request_json = request.get_json() topic_name = request_json["topic"] topic_path = pubsub.topic_path(project, topic_name) # Process the request data = b"Test message" pubsub.publish(topic_path, data=data) return https_fn.Response("1 message published")
ฟังก์ชัน HTTP นี้ใช้อินสแตนซ์ไลบรารีของไคลเอ็นต์ที่แคชไว้เพื่อลดจำนวนการเชื่อมต่อที่จำเป็นต่อการเรียกใช้ฟังก์ชัน
ซึ่งจะใช้ออบเจ็กต์คำขอ (flask.Request
) และแสดงผลข้อความตอบกลับ หรือชุดค่าที่เปลี่ยนเป็นออบเจ็กต์ Response
ได้โดยใช้ make_response
ระบบจะตั้งค่าตัวแปรสภาพแวดล้อม GCP_PROJECT
โดยอัตโนมัติในรันไทม์ของ Python 3.7 ในรันไทม์ภายหลัง อย่าลืมระบุการทำให้ใช้งานได้ของฟังก์ชัน โปรดดูหัวข้อกำหนดค่าตัวแปรสภาพแวดล้อม
ทดสอบการโหลดฟังก์ชันของคุณ
หากต้องการวัดจำนวนการเชื่อมต่อโดยเฉลี่ยที่ฟังก์ชันของคุณทำงานได้ เพียงทำให้ฟังก์ชันนั้นเป็นฟังก์ชัน HTTP ใช้งานได้และใช้เฟรมเวิร์กการทดสอบประสิทธิภาพเพื่อเรียกใช้ QPS ที่ต้องการ ตัวเลือกหนึ่งที่เป็นไปได้คือ Artillery ซึ่งสามารถเรียกใช้ได้ด้วยบรรทัดเดียว ดังนี้
$ artillery quick -d 300 -r 30 URL
คำสั่งนี้จะดึงข้อมูล URL ที่ระบุที่ 30 QPS เป็นเวลา 300 วินาที
หลังจากทดสอบแล้ว ให้ตรวจสอบการใช้งานโควต้าการเชื่อมต่อในหน้าโควต้า Cloud Functions API ใน Cloud Console หากการใช้งานอยู่ที่ประมาณ 30 ครั้ง (หรือหลายรายการ) อย่างสม่ำเสมอ คุณกำลังสร้างการเชื่อมต่อ 1 (หรือหลายรายการ) ในทุกๆ คำขอ หลังจากที่คุณเพิ่มประสิทธิภาพโค้ดแล้ว คุณควรจะเห็นการเชื่อมต่อ 2-3 รายการ (10-30) เกิดขึ้นในช่วงเริ่มต้นของการทดสอบเท่านั้น
นอกจากนี้ คุณยังสามารถเปรียบเทียบต้นทุน CPU ก่อนและหลังการเพิ่มประสิทธิภาพบนแผนโควต้า CPU ในหน้าเดียวกัน