رفع خطای ۵۰۲ در انجین‌اکس؛ عیب‌یابی مرحله‌ای

نام فایل: upstream.py؛ همهٔ سطرها را با همین نام ذخیره کنید.

from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer


class Handler(BaseHTTPRequestHandler):
    def do_GET(self):
        body = b'upstream ready\n'
        self.send_response(200)
        self.send_header('Content-Type', 'text/plain')
        self.send_header('Content-Length', str(len(body)))
        self.end_headers()
        self.wfile.write(body)


if __name__ == '__main__':
    ThreadingHTTPServer(('127.0.0.1', 8091), Handler).serve_forever()

این فایل بخشی از مثال کامل بالاست؛ ترتیب اجرا، پیش‌نیازها و محدودیت‌های نتیجه در متن مقاله توضیح داده شده است.

نام فایل: nginx.conf؛ همهٔ سطرها را با همین نام ذخیره کنید.

worker_processes 1;
pid nginx-demo.pid;
error_log stderr notice;
events { worker_connections 64; }
http {
  log_format upstream_timing '$request_id $status upstream=$upstream_status '
    'connect=$upstream_connect_time header=$upstream_header_time total=$request_time';
  access_log /dev/stdout upstream_timing;
  server {
    listen 127.0.0.1:8090;
    location / {
      proxy_pass http://127.0.0.1:8091;
      proxy_set_header Host $host;
      proxy_set_header X-Request-ID $request_id;
      proxy_connect_timeout 2s;
      proxy_read_timeout 5s;
    }
  }
}

این فایل بخشی از مثال کامل بالاست؛ ترتیب اجرا، پیش‌نیازها و محدودیت‌های نتیجه در متن مقاله توضیح داده شده است.

نام فایل: diagnose.py؛ همهٔ سطرها را با همین نام ذخیره کنید.

import argparse
import json
import urllib.error
import urllib.request


def probe(url):
    try:
        with urllib.request.urlopen(url, timeout=7) as response:
            return {'status': response.status, 'error': None}
    except urllib.error.HTTPError as error:
        return {'status': error.code, 'error': 'http'}
    except OSError:
        return {'status': None, 'error': 'connection-or-timeout'}


def classify(gateway, upstream):
    if upstream['status'] is None:
        return 'upstream-unreachable-from-this-client'
    if gateway['status'] == 502 and upstream['status'] == 200:
        return 'inspect-proxy-route-protocol-and-network-namespace'
    if gateway['status'] == upstream['status'] == 200:
        return 'healthy-at-check-time'
    return 'inspect-status-and-correlated-server-logs'


if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('--gateway', default='http://127.0.0.1:8090/')
    parser.add_argument('--upstream', default='http://127.0.0.1:8091/')
    args = parser.parse_args()
    gateway, upstream = probe(args.gateway), probe(args.upstream)
    print(json.dumps({'gateway': gateway, 'upstream': upstream, 'assessment': classify(gateway, upstream)}))

این فایل بخشی از مثال کامل بالاست؛ ترتیب اجرا، پیش‌نیازها و محدودیت‌های نتیجه در متن مقاله توضیح داده شده است.

نام فایل: test_diagnose.py؛ همهٔ سطرها را با همین نام ذخیره کنید.

import threading
import unittest
from http.server import ThreadingHTTPServer
from diagnose import classify, probe
from upstream import Handler


class DiagnosisTests(unittest.TestCase):
    def test_real_upstream(self):
        server = ThreadingHTTPServer(('127.0.0.1', 0), Handler)
        worker = threading.Thread(target=server.serve_forever, daemon=True)
        worker.start()
        try:
            result = probe(f'http://127.0.0.1:{server.server_port}/')
            self.assertEqual(result['status'], 200)
            self.assertEqual(classify(result, result), 'healthy-at-check-time')
        finally:
            server.shutdown()
            server.server_close()
            worker.join()

    def test_proxy_only_failure(self):
        self.assertIn('proxy-route', classify({'status': 502}, {'status': 200}))

    def test_connection_failure_is_not_http_status(self):
        self.assertIn('unreachable', classify({'status': 502}, {'status': None}))


if __name__ == '__main__':
    unittest.main()

این فایل بخشی از مثال کامل بالاست؛ ترتیب اجرا، پیش‌نیازها و محدودیت‌های نتیجه در متن مقاله توضیح داده شده است.