MaxCompute:IP アドレスを使用した HTTPS サービスへのアクセス

1. リモートサービスの IP アドレスを取得します。

ping service.cn-shanghai-vpc.maxcompute.aliyun-inc.com

2. HTTP クライアントを設定します。

次のコードサンプルは、異なる Python バージョン向けにカスタム HTTP アダプターを作成する方法を示しています。このアダプターは、リクエスト URL では IP アドレスを送信しますが、SSL 証明書の検証には Host ヘッダーで元のドメイン名を使用します。タスクを公開する前に、正しいネットワーク環境からリモートアクセスをテストしてください。

• Python 2

  # _*_ coding: utf-8 _*_
  # Python 2 専用
  import requests
  from urlparse import urlparse
  class HostHeaderSSLAdapter(requests.adapters.HTTPAdapter):
      def __init__(self, resolved_ip):
          super(HostHeaderSSLAdapter,self).__init__()
          self.resolved_ip = resolved_ip
      def send(self, request, **kwargs):
          connection_pool_kwargs = self.poolmanager.connection_pool_kw
          result = urlparse(request.url)
          if result.scheme == 'https' and self.resolved_ip:
              request.url = request.url.replace(
                  'https://' + result.hostname,
                  'https://' + self.resolved_ip,
              )
              connection_pool_kwargs['assert_hostname'] = result.hostname
              request.headers['Host'] = result.hostname
          else:
              connection_pool_kwargs.pop('assert_hostname', None)
          return super(HostHeaderSSLAdapter, self).send(request, **kwargs)
  def access_url(url, resolved_ip):
      session = requests.Session()
      # URL からホスト名を取得します。
      parsed_url = urlparse(url)
      hostname = parsed_url.hostname
      session.mount('https://'+hostname, HostHeaderSSLAdapter(resolved_ip))
      try:
          r = session.get(url)
      except Exception as e:
          print("Error: "+ str(e))
      else:
          if r.status_code != 200:
              print("Request failed with non-200 status. Response: "+ r.text)
          else:
              print("Success. Response: "+ r.text)
  if __name__ == "__main__":
      # VPC 環境内のドメイン名に対して 'dig' を使用して IP アドレスを取得します。
      # VPC アドレスをテストします。
      #access_url("https://service.cn-shanghai-vpc.maxcompute.aliyun-inc.com", "100.103.104.45")
      # パブリックネットワークアドレスをテストします。
      access_url("https://service.cn-shanghai.maxcompute.aliyun.com", "47.116.XX.XX")

• Python 3

  # _*_ coding: utf-8 _*_
  import requests
  from urllib.parse import urlparse 
  class HostHeaderSSLAdapter(requests.adapters.HTTPAdapter):
      def __init__(self, resolved_ip):
          super().__init__()                                        
          self.resolved_ip = resolved_ip
      def send(self, request, **kwargs):
          connection_pool_kwargs = self.poolmanager.connection_pool_kw
          result = urlparse(request.url)
          if result.scheme == 'https' and self.resolved_ip:
              request.url = request.url.replace(
                  'https://' + result.hostname,
                  'https://' + self.resolved_ip,
              )
              connection_pool_kwargs['server_hostname'] = result.hostname  
              # Host ヘッダーを上書きします。
              request.headers['Host'] = result.hostname
          else:
              # 前回のリクエストから残っている可能性のあるヘッダーをクリアします。
              connection_pool_kwargs.pop('server_hostname', None)           
          return super().send(request, **kwargs)
  def access_url(url, resolved_ip):
      session = requests.Session()
      # URL からホスト名を取得します。
      parsed_url = urlparse(url)
      hostname = parsed_url.hostname
      session.mount('https://'+hostname, HostHeaderSSLAdapter(resolved_ip))
      try:
          r = session.get(url)
      except Exception as e:
          print("Error: "+ str(e))
      else:
          if r.status_code != 200:
              print("Request failed with non-200 status. Response: "+ r.text)
          else:
              print("Success. Response: "+ r.text)
  if __name__ == "__main__":
      # VPC 環境内のドメイン名に対して 'dig' を使用して IP アドレスを取得します。
      # VPC アドレスをテストします。
      #access_url("https://service.cn-shanghai-vpc.maxcompute.aliyun-inc.com", "100.103.104.45")
      # パブリックネットワークアドレスをテストします。
      access_url("https://service.cn-shanghai.maxcompute.aliyun.com", "47.116.XX.XX")

テスト結果

• ローカルマシンからパブリックネットワーク経由で MaxCompute サービスにアクセスします。

  if __name__ == "__main__":
      access_url( url="https://service.cn-shanghai.maxcompute.aliyun.com", resolved_ip="47.116.XX.XX")
  "D:\Program Files\Python311\python.exe" D:\ProgramData\PycharmProjects\pythontest1\text.py
  Success. Response: <!DOCTYPE html>
  <html>
  <head>
  <title>Welcome to tengine!</title>
  <style>
      body {
              width: 35em;
              margin: 0 auto;
              font-family: Tahoma, Verdana, Arial, sans-serif;
      }
  </style>
  </head>
  <body>
  <h1>Welcome to tengine!</h1>
  <p>If you see this page, the tengine web server is successfully installed and
  working. Further configuration is required.</p>
  <p>For online documentation and support please refer to
  <a href="http://tengine.taobao.org/">tengine.taobao.org</a>.</p>
  <p><em>Thank you for using tengine.</em></p>
  </body>
  </html>

• Linux ECS インスタンスからパブリックネットワーク経由で MaxCompute サービスにアクセスします。

  [root@iZbp1ehm6ky76ig8n1jd8dZ opt]# python3 text.py
  Success. Response: <!DOCTYPE html>
  <html>
  <head>
  <title>Welcome to tengine!</title>
  <style>
      body {
          width: 35em;
          margin: 0 auto;
          font-family: Tahoma, Verdana, Arial, sans-serif;
      }
  </style>
  </head>
  <body>
  <h1>Welcome to tengine!</h1>
  <p>If you see this page, the tengine web server is successfully installed and
  working. Further configuration is required.</p>
  <p>For online documentation and support please refer to
  <a href="http://tengine.taobao.org/">tengine.taobao.org</a>.</p>
  <p><em>Thank you for using tengine.</em></p>
  </body>
  </html>