प्रौद्योगिकी साझेदारी

WSGI सर्वर पाठ्यक्रम: `start_response` विधि विश्लेषण

2024-07-12

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

पायथन् WSGI सर्वर पाठ्यक्रमः : १.start_response विधिविश्लेषणम्

अस्मिन् लेखे वयं WSGI सर्वरस्य विस्तरेण विश्लेषणं करिष्यामः start_response प्रक्रिया।एषा पद्धतिः HTTP प्रतिक्रियायाः स्थितिसङ्केतः प्रतिक्रियाशीर्षकाणां च संसाधनं कृत्वा awrite प्रतिक्रियादत्तांशं प्रेषयितुं प्रयुक्तं कार्यं । वयं व्याख्यास्यामः यत् विधिः कथं पङ्क्तिपङ्क्तिं कार्यं करोति तथा च तस्य क्षमतां अवगन्तुं साहाय्यं कर्तुं किञ्चित् पृष्ठभूमिं प्रदास्यामः ।

पृष्ठभूमि ज्ञान

WSGI (Web Server Gateway Interface) इति मानक-अन्तरफलकं जाल-सर्वरं जाल-अनुप्रयोगेन वा ढाञ्चेन सह संयोजयितुं उपयुज्यते । WSGI इत्यस्य माध्यमेन भवान् सर्वरस्य अनुप्रयोगस्य च मध्ये संवादं कर्तुं शक्नोति तथा च HTTP अनुरोधानाम् प्रतिक्रियाणां च निबन्धनं कर्तुं शक्नोति ।

WSGI सर्वरस्य कार्यान्वयनसमये,start_response विधिः एकः प्रमुखः भागः अस्ति यः WSGI अनुप्रयोगेन HTTP प्रतिक्रियास्थितिं प्रतिक्रियाशीर्षकं च सेट् कर्तुं आह्वयति, प्रतिक्रियादत्तांशलेखनार्थं च कार्यं प्रत्यागच्छति

start_response विधि कार्यान्वयन

निम्नलिखितम् एकः विशिष्टः अस्ति start_response विधि कार्यान्वयनम् : १.

def start_response(status, response_headers, exc_info=None):
    if exc_info:
        try:
            if headers_sent:
                reraise(*exc_info)
        finally:
            exc_info = None
    elif headers_set:
        raise AssertionError("Headers already set")
    headers_set[:] = [status, response_headers]
    return write
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11

पदे पदे व्याख्यानम्

  1. निबध्नाति exc_info पैरामीटर्
if exc_info:
    try:
        if headers_sent:
            reraise(*exc_info)
    finally:
        exc_info = None
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • exc_info तर्के प्रायः प्रारूपे अपवाद-ट्यूपल् भवति(type, value, traceback) , अपवादनियन्त्रणार्थं प्रयुक्तम् ।यदिexc_info न हिNone, अपवादः अस्ति इति सूचयति यस्य निबन्धनं करणीयम् ।
  • try इन-ब्लॉक चेकheaders_sent प्रतिक्रियाशीर्षकं प्रेषितम् अस्ति वा।यदि प्रतिक्रियाशीर्षकाणि प्रेषितानि सन्ति तर्हि आह्वानं कुर्वन्तुreraise(*exc_info) अपवादं पुनः क्षिपतु।
  • finally block सुनिश्चितं करोति यत् अपवादस्य निबन्धनस्य अनन्तरं, theexc_info इति सेट् कृतम्Noneप्रसंस्करणस्य द्वितीयकं परिहरितुं।
  1. प्रतिक्रियाशीर्षकं सेट् कृतम् अस्ति वा इति पश्यन्तु
elif headers_set:
    raise AssertionError("Headers already set")
  • 1
  • 2
  • यदि headers_set सूचीयां पूर्वमेव मूल्यानि सन्ति (अर्थात् प्रतिक्रियाशीर्षकं सेट् कृतम् अस्ति), उत्थापयतिAssertionError असामान्यम् ।एषा जाँचः सुनिश्चितं करोतिstart_response प्रतिक्रियाशीर्षकाणि सेट् कर्तुं एकवारं एव आह्वयितुं शक्यते ।
  1. प्रतिक्रियास्थितिः प्रतिक्रियाशीर्षकाणि च सेट् कुर्वन्तु
headers_set[:] = [status, response_headers]
  • 1
  • to slice assignment इत्यस्य उपयोगं कुर्वन्तु status तथाresponse_headers नियुक्तःheaders_set सूची।अस्य प्रयोजनं धारणम्headers_set सन्दर्भं, परन्तु तस्य सामग्रीं अद्यतनं करोति ।
  • status HTTP प्रतिक्रियास्थितिसङ्केतं सन्देशं च प्रतिनिधियति इति स्ट्रिंग् अस्ति, उदाहरणार्थम्"200 OK"
  • response_headers ट्युपल्स् युक्ता सूची अस्ति, प्रत्येकं ट्युपल् प्रतिक्रियाशीर्षकस्य कील-मूल्ययुगलं प्रतिनिधियति, उदाहरणार्थम्[("Content-Type", "text/html"), ("Content-Length", "123")]
  1. निर्वतनम् write नियोग
return write
  • 1
  • start_response विधिः a प्रत्यागच्छतिwrite नियोग। प्रतिक्रियादत्तांशं प्रेषयितुं WSGI अनुप्रयोगेन एतत् कार्यं आह्वयते ।

प्रयोगोदाहरणम्

अत्र कथं उपयोगः करणीयः इति दर्शयति सम्पूर्णं उदाहरणम् अस्ति start_response WSGI प्रतिक्रियाः नियन्त्रयितुं पद्धतयः : १.

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        self.headers_set = []
        self.headers_sent = []

        def start_response(status, response_headers, exc_info=None):
            if exc_info:
                try:
                    if self.headers_sent:
                        raise exc_info[1]
                finally:
                    exc_info = None
            elif self.headers_set:
                raise AssertionError("Headers already set")
            self.headers_set[:] = [status, response_headers]
            return self.write

        def write(data):
            assert self.headers_set, "write() before start_response"
            if not self.headers_sent:
                status, response_headers = self.headers_sent[:] = self.headers_set
                try:
                    code, msg = status.split(None, 1)
                except ValueError:
                    code, msg = status, ""
                code = int(code)
                self.send_response(code, msg)
                header_keys = set()
                for key, value in response_headers:
                    self.send_header(key, value)
                    key = key.lower()
                    header_keys.add(key)
                if not (
                    "content-length" in header_keys
                    or self.environ["REQUEST_METHOD"] == "HEAD"
                    or code < 200
                    or code in (204, 304)
                ):
                    self.close_connection = True
                    self.send_header("Connection", "close")
                if "server" not in header_keys:
                    self.send_header("Server", self.version_string())
                if "date" not in header_keys:
                    self.send_header("Date", self.date_time_string())
                self.end_headers()

            assert isinstance(data, bytes), "applications must write bytes"
            self.wfile.write(data)
            self.wfile.flush()

        self.write = write
        self.environ = self.make_environ()

        try:
            result = self.server.app(self.environ, start_response)
            try:
                for data in result:
                    write(data)
                if not self.headers_sent:
                    write(b"")
            finally:
                if hasattr(result, "close"):
                    result.close()
        except Exception as e:
            self.send_error(500, str(e))

if __name__ == "__main__":
    HOST, PORT = "localhost", 9999
    with socketserver.TCPServer((HOST, PORT), MyTCPHandler) as server:
        print("Server started at {}:{}".format(HOST, PORT))
        server.serve_forever()
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73

सारांशं कुरुत

अस्य पाठ्यक्रमस्य माध्यमेन वयं WSGI सर्वरस्य विस्तरेण विश्लेषणं कृतवन्तः start_response विधिः या व्याख्यायते यत् एतत् HTTP प्रतिक्रियायाः स्थितिसङ्केतं प्रतिक्रियाशीर्षकं च कथं नियन्त्रयति, प्रतिक्रियादत्तांशलेखनार्थं च कार्यं प्रत्यागच्छति । एताः सामग्रीः अवगत्य WSGI विनिर्देशं अधिकतया ग्रहीतुं अनुकूलितं WSGI सर्वरं कार्यान्वितुं च सहायकं भविष्यति । आशास्ति यत् एतत् पाठ्यक्रमं भवद्भ्यः सहायकं भविष्यति।अधिकविवरणार्थं उदाहरणार्थं च कृपया पश्यन्तुआधिकारिक दस्तावेजीकरण