Python で Notification Hubs を使用する方法

[アーティクル]
06/01/2023

MSDN のトピック「 Notification Hubs REST API (Notification Hubs の REST API)」の記事にあるように、Notification Hubs の REST インターフェイスを使用して、Java/PHP/Python/Ruby バックエンドから Notification Hubs のすべての機能にアクセスできます。

Note

これは Python で、通知の送信を実装するためのサンプル参照実装であり、正式にサポートされている通知ハブの Python SDK ではありません。サンプルは Python 3.4 を使用して作成されました。

この記事で取り上げるテクニック:

Python で Notification Hubs 機能の REST クライアントを記述します。
通知ハブ REST API には、Python インターフェイスを使用して通知を送信します。
デバッグ/教育目的のための HTTP REST 要求/応答のダンプを取得します。

選択したモバイルプラットフォームの「 Notification Hubs の使用」に従って、Python のバックエンド部分を実装します。

Note

このサンプルの範囲は通知の送信のみに制限され、登録の管理は行いません。

クライアントインターフェイス

メインクライアントインターフェイスは、 .NET Notification Hubs SDKで利用可能なものと同じメソッドを提供できます。このインターフェイスにより、現在このサイトで使用可能であり、インターネット上のコミュニティによって提供されたすべてのチュートリアルとサンプルを直接変換できます。

Python REST ラッパーサンプルで利用可能なすべてのコードを検索できます。

たとえば、クライアントを作成する場合:

isDebug = True
hub = NotificationHub("myConnectionString", "myNotificationHubName", isDebug)

Windows トースト通知を送信する場合:

wns_payload = """<toast><visual><binding template=\"ToastText01\"><text id=\"1\">Hello world!</text></binding></visual></toast>"""
hub.send_windows_notification(wns_payload)

実装

まだ実行していない場合は、「Notification Hubs の使用」のチュートリアルの、バックエンドを実装する必要のある最後のセクションまで従ってください。

REST ラッパーすべての実装の詳細については、 MSDN の記事を参照してください。このセクションでは、Notification Hubs REST エンドポイントにアクセスし、通知を送信するために必要な主要な手順の Python 実装について説明します。

接続文字列を解析する
認証トークンを生成する
HTTP REST API を使用して通知を送信する

接続文字列を解析する

接続文字列を解析するコンストラクターを持つクライアントを実装するメインクラスです。

class NotificationHub:
    API_VERSION = "?api-version=2013-10"
    DEBUG_SEND = "&test"

    def __init__(self, connection_string=None, hub_name=None, debug=0):
        self.HubName = hub_name
        self.Debug = debug

        # Parse connection string
        parts = connection_string.split(';')
        if len(parts) != 3:
            raise Exception("Invalid ConnectionString.")

        for part in parts:
            if part.startswith('Endpoint'):
                self.Endpoint = 'https' + part[11:].lower()
            if part.startswith('SharedAccessKeyName'):
                self.SasKeyName = part[20:]
            if part.startswith('SharedAccessKey'):
                self.SasKeyValue = part[16:]

セキュリティトークンを作成する

セキュリティトークンの作成の詳細については、こちらをご覧ください。現在の要求の URI と接続文字列から抽出された資格情報に基づいてトークンを作成するには、NotificationHub クラスに次のメソッドを追加します。

@staticmethod
def get_expiry():
    # By default returns an expiration of 5 minutes (=300 seconds) from now
    return int(round(time.time() + 300))


@staticmethod
def encode_base64(data):
    return base64.b64encode(data)


def sign_string(self, to_sign):
    key = self.SasKeyValue.encode('utf-8')
    to_sign = to_sign.encode('utf-8')
    signed_hmac_sha256 = hmac.HMAC(key, to_sign, hashlib.sha256)
    digest = signed_hmac_sha256.digest()
    encoded_digest = self.encode_base64(digest)
    return encoded_digest


def generate_sas_token(self):
    target_uri = self.Endpoint + self.HubName
    my_uri = urllib.parse.quote(target_uri, '').lower()
    expiry = str(self.get_expiry())
    to_sign = my_uri + '\n' + expiry
    signature = urllib.parse.quote(self.sign_string(to_sign))
    auth_format = 'SharedAccessSignature sig={0}&se={1}&skn={2}&sr={3}'
    sas_token = auth_format.format(signature, expiry, self.SasKeyName, my_uri)
    return sas_token

HTTP REST API を使用して通知を送信する

Note

Microsoft プッシュ通知サービス (MPNS) は非推奨とされ、サポートされなくなりました。

最初に、通知を表すクラスの定義を使用します。

class Notification:
    def __init__(self, notification_format=None, payload=None, debug=0):
        valid_formats = ['template', 'apple', 'gcm',
                         'windows', 'windowsphone', "adm", "baidu"]
        if not any(x in notification_format for x in valid_formats):
            raise Exception(
                "Invalid Notification format. " +
                "Must be one of the following - 'template', 'apple', 'gcm', 'windows', 'windowsphone', 'adm', 'baidu'")

        self.format = notification_format
        self.payload = payload

        # array with keynames for headers
        # Note: Some headers are mandatory: Windows: X-WNS-Type, WindowsPhone: X-NotificationType
        # Note: For Apple you can set Expiry with header: ServiceBusNotification-ApnsExpiry
        # in W3C DTF, YYYY-MM-DDThh:mmTZD (for example, 1997-07-16T19:20+01:00).
        self.headers = None

このクラスは、ネイティブ通知の本文またはテンプレート通知の一連のプロパティ、形式 (ネイティブなプラットフォームまたはテンプレート) とプラットフォーム固有のプロパティ (Apple の有効期限プロパティや WNS ヘッダーなど) を含む一連のヘッダーのコンテナーです。

使用可能なすべてのオプションについては、Notification Hubs REST API のドキュメントおよび特定の通知プラットフォームの形式を参照してください。

次に、このクラスを使用して、NotificationHub クラス内に通知の送信メソッドを記述します。

def make_http_request(self, url, payload, headers):
    parsed_url = urllib.parse.urlparse(url)
    connection = http.client.HTTPSConnection(
        parsed_url.hostname, parsed_url.port)

    if self.Debug > 0:
        connection.set_debuglevel(self.Debug)
        # adding this querystring parameter gets detailed information about the PNS send notification outcome
        url += self.DEBUG_SEND
        print("--- REQUEST ---")
        print("URI: " + url)
        print("Headers: " + json.dumps(headers, sort_keys=True,
                                       indent=4, separators=(' ', ': ')))
        print("--- END REQUEST ---\n")

    connection.request('POST', url, payload, headers)
    response = connection.getresponse()

    if self.Debug > 0:
        # print out detailed response information for debugging purpose
        print("\n\n--- RESPONSE ---")
        print(str(response.status) + " " + response.reason)
        print(response.msg)
        print(response.read())
        print("--- END RESPONSE ---")

    elif response.status != 201:
        # Successful outcome of send message is HTTP 201 - Created
        raise Exception(
            "Error sending notification. Received HTTP code " + str(response.status) + " " + response.reason)

    connection.close()


def send_notification(self, notification, tag_or_tag_expression=None):
    url = self.Endpoint + self.HubName + '/messages' + self.API_VERSION

    json_platforms = ['template', 'apple', 'gcm', 'adm', 'baidu']

    if any(x in notification.format for x in json_platforms):
        content_type = "application/json"
        payload_to_send = json.dumps(notification.payload)
    else:
        content_type = "application/xml"
        payload_to_send = notification.payload

    headers = {
        'Content-type': content_type,
        'Authorization': self.generate_sas_token(),
        'ServiceBusNotification-Format': notification.format
    }

    if isinstance(tag_or_tag_expression, set):
        tag_list = ' || '.join(tag_or_tag_expression)
    else:
        tag_list = tag_or_tag_expression

    # add the tags/tag expressions to the headers collection
    if tag_list != "":
        headers.update({'ServiceBusNotification-Tags': tag_list})

    # add any custom headers to the headers collection that the user may have added
    if notification.headers is not None:
        headers.update(notification.headers)

    self.make_http_request(url, payload_to_send, headers)


def send_apple_notification(self, payload, tags=""):
    nh = Notification("apple", payload)
    self.send_notification(nh, tags)


def send_google_notification(self, payload, tags=""):
    nh = Notification("gcm", payload)
    self.send_notification(nh, tags)


def send_adm_notification(self, payload, tags=""):
    nh = Notification("adm", payload)
    self.send_notification(nh, tags)


def send_baidu_notification(self, payload, tags=""):
    nh = Notification("baidu", payload)
    self.send_notification(nh, tags)


def send_mpns_notification(self, payload, tags=""):
    nh = Notification("windowsphone", payload)

    if "<wp:Toast>" in payload:
        nh.headers = {'X-WindowsPhone-Target': 'toast',
                      'X-NotificationClass': '2'}
    elif "<wp:Tile>" in payload:
        nh.headers = {'X-WindowsPhone-Target': 'tile',
                      'X-NotificationClass': '1'}

    self.send_notification(nh, tags)


def send_windows_notification(self, payload, tags=""):
    nh = Notification("windows", payload)

    if "<toast>" in payload:
        nh.headers = {'X-WNS-Type': 'wns/toast'}
    elif "<tile>" in payload:
        nh.headers = {'X-WNS-Type': 'wns/tile'}
    elif "<badge>" in payload:
        nh.headers = {'X-WNS-Type': 'wns/badge'}

    self.send_notification(nh, tags)


def send_template_notification(self, properties, tags=""):
    nh = Notification("template", properties)
    self.send_notification(nh, tags)

これらのメソッドは、通知ハブの /messages エンドポイントに、通知を送信するための正しい本文とヘッダーを含む HTTP POST 要求を送信します。

デバッグプロパティを使用して、詳細なログ記録を有効にする

Notification Hub の初期化中にデバッグプロパティを有効にすると、HTTP 要求に関する詳細なログ情報や応答ダンプ、さらには詳細な通知メッセージの送信結果が書き込まれます。 Notification Hubs TestSend プロパティは、通知の送信結果に関する詳細情報を返します。これを使用するには、次のコードを使用して初期化します。

hub = NotificationHub("myConnectionString", "myNotificationHubName", isDebug)

結果として HTTP URL が取得する通知ハブの送信要求には、"test" クエリ文字列が追加されます。

チュートリアルの完了

ここで、Python バックエンドから通知を送信して、使用についてのチュートリアルを完了できます。

Notification Hubs クライアントを初期化します (「 Notification Hubs の使用」の説明に従って接続文字列とハブ名を置き換えます)。

hub = NotificationHub("myConnectionString", "myNotificationHubName")

次に、ターゲットモバイルプラットフォームに応じて送信コードを追加します。このサンプルではまた、プラットフォームに基づいた通知の送信を有効にするためのより高レベルのメソッド (たとえば、Windows 用の send_windows_notification や Apple 用の send_apple_notification など) も追加します。

Windows ストアおよび Windows Phone 8.1 (非 Silverlight)

wns_payload = """<toast><visual><binding template=\"ToastText01\"><text id=\"1\">Test</text></binding></visual></toast>"""
hub.send_windows_notification(wns_payload)

Windows Phone 8.0 および 8.1 Silverlight

hub.send_mpns_notification(toast)

iOS

alert_payload = {
    'data':
        {
            'msg': 'Hello!'
        }
}
hub.send_apple_notification(alert_payload)

Android

gcm_payload = {
    'data':
        {
            'msg': 'Hello!'
        }
}
hub.send_google_notification(gcm_payload)

Kindle Fire

adm_payload = {
    'data':
        {
            'msg': 'Hello!'
        }
}
hub.send_adm_notification(adm_payload)

Baidu

baidu_payload = {
    'data':
        {
            'msg': 'Hello!'
        }
}
hub.send_baidu_notification(baidu_payload)

Python コードを実行すると、ターゲットデバイスに表示される通知が生成されます。

例

`debug` プロパティの有効化

NotificationHub の初期化中にデバッグフラグを有効にすると、次のように詳細な HTTP 要求や応答ダンプ、さらには NotificationOutcome が表示されます。これにより、要求でどのような HTTP ヘッダーが渡され、Notification Hub からどのような HTTP 応答が受信されたかを理解できます。

HTTP 要求や HTTP 応答のダンプ、および Notification Outcome メッセージの詳細が赤色の枠線で囲まれているコンソールのスクリーンショット。

たとえば、Notification Hub の詳細な結果が表示されます。

例: プッシュ通知サービスにメッセージが正常に送信される場合。

<Outcome>The Notification was successfully sent to the Push Notification System</Outcome>

いずれかのプッシュ通知のターゲットが見つからなかった場合は、応答として次の出力が表示される可能性があります (これは、登録のいくつかのタグが一致しないなどのために、通知を配信するための登録が見つからなかったことを示します)。
```
'<NotificationOutcome xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" xmlns:i="https://www.w3.org/2001/XMLSchema-instance"><Success>0</Success><Failure>0</Failure><Results i:nil="true"/></NotificationOutcome>'
```

Windows にトースト通知をブロードキャストする

ブロードキャストのトースト通知を Windows クライアントに送信するときにヘッダーも送信されることに注意してください。

hub.send_windows_notification(wns_payload)

HTTP 要求、および Service Bus Notification 形式と X-WNS 型の各値の詳細が赤色の枠線で囲まれているコンソールのスクリーンショット。

タグ (またはタグ式) を指定して通知を送信する

HTTP 要求に追加される Tags HTTP ヘッダーに注意してください (次の例では、通知は 'sports' ペイロードを含む登録にのみ送信されます)。

hub.send_windows_notification(wns_payload, "sports")

HTTP 要求、および Service Bus Notification 形式、Service Bus Notification タグ、X-WNS 型の各値の詳細が赤色の枠線で囲まれているコンソールのスクリーンショット。

複数のタグを指定すて通知を送信する

複数のタグが送信される場合に HTTP ヘッダーが変更するタグに注意してください。

tags = {'sports', 'politics'}
hub.send_windows_notification(wns_payload, tags)

HTTP 要求、および Service Bus Notification 形式、複数の Service Bus Notification タグ、X-WNS 型の各値の詳細が赤色の枠線で囲まれているコンソールのスクリーンショット。

テンプレート化された通知

HTTP ヘッダーが変更する形式と、ペイロードの本文が HTTP 要求本文の一部として送信されることに注意してください。

クライアント側 - 登録済みのテンプレート:

var template = @"<toast><visual><binding template=""ToastText01""><text id=""1"">$(greeting_en)</text></binding></visual></toast>";

サーバー側 - ペイロードの送信:

template_payload = {'greeting_en': 'Hello', 'greeting_fr': 'Salut'}
hub.send_template_notification(template_payload)

HTTP 要求、およびコンテンツの種類、Service Bus Notification 形式の各値の詳細が赤色の枠線で囲まれているコンソールのスクリーンショット。

次の手順

この記事では、Notification Hubs 用の Python REST クライアントを作成する方法を示しました。ここでは、次の操作を実行できます。

この記事のすべてのコードを含む完全な Python REST ラッパーサンプルをダウンロードします。
引き続き、「ニュース速報チュートリアル
引き続き、「ローカライズ版のニュース速報チュートリアル

次の方法で共有

Python で Notification Hubs を使用する方法

クライアントインターフェイス

実装

接続文字列を解析する

セキュリティトークンを作成する

HTTP REST API を使用して通知を送信する

デバッグプロパティを使用して、詳細なログ記録を有効にする

チュートリアルの完了

Windows ストアおよび Windows Phone 8.1 (非 Silverlight)

Windows Phone 8.0 および 8.1 Silverlight

iOS

Android

Kindle Fire

Baidu

例

`debug` プロパティの有効化

Windows にトースト通知をブロードキャストする

タグ (またはタグ式) を指定して通知を送信する

複数のタグを指定すて通知を送信する

テンプレート化された通知

次の手順

フィードバック

その他のリソース

次の方法で共有

Python で Notification Hubs を使用する方法

クライアント インターフェイス

実装

接続文字列を解析する

セキュリティ トークンを作成する

HTTP REST API を使用して通知を送信する

デバッグ プロパティを使用して、詳細なログ記録を有効にする

チュートリアルの完了

Windows ストアおよび Windows Phone 8.1 (非 Silverlight)

Windows Phone 8.0 および 8.1 Silverlight

iOS

Android

Kindle Fire

Baidu

例

debug プロパティの有効化

Windows にトースト通知をブロードキャストする

タグ (またはタグ式) を指定して通知を送信する

複数のタグを指定すて通知を送信する

テンプレート化された通知

次の手順

フィードバック

その他のリソース

クライアントインターフェイス

セキュリティトークンを作成する

デバッグプロパティを使用して、詳細なログ記録を有効にする

`debug` プロパティの有効化