翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
クライアントは、HTTP 1.0 または 1.1 プロトコルを使用して REST API にリクエストを実行することで、メッセージをパブリッシュできます。HTTP リクエストで使用される認証およびポートマッピングについては、「プロトコル、ポートマッピング、認証」を参照してください。
注記
HTTPS は MQTT のような clientId 値をサポートしていません。clientId は MQTT を使用する場合は使用できますが、HTTPS を使用する場合は使用できません。
HTTPS メッセージ URL
デバイスとクライアントは、クライアント固有のエンドポイントとトピック固有の URL に POST リクエストを行うことで、メッセージを発行します。
https://IoT_data_endpoint/topics/url_encoded_topic_name?qos=1
-
IoT_data_endpointは、AWS IoT デバイスのデータエンドポイントです。コマンドを使用して AWS CLI 、 AWS IoT コンソールのモノの詳細ページまたはクライアントでエンドポイントを見つけることができます。aws iot describe-endpoint --endpoint-type iot:Data-ATSエンドポイントは次のようになります:
a3qjEXAMPLEffp-ats.iot.us-west-2.amazonaws.com -
url_encoded_topic_nameは、送信されるメッセージの完全なトピック名です。
HTTPS メッセージコードの例
AWS IoTに HTTPS メッセージを送信する方法の例をいくつか示します。
import requests
import argparse
# define command-line parameters
parser = argparse.ArgumentParser(description="Send messages through an HTTPS connection.")
parser.add_argument('--endpoint', required=True, help="Your AWS IoT data custom endpoint, not including a port. " +
"Ex: \"abcdEXAMPLExyz-ats.iot.us-east-1.amazonaws.com\"")
parser.add_argument('--cert', required=True, help="File path to your client certificate, in PEM format.")
parser.add_argument('--key', required=True, help="File path to your private key, in PEM format.")
parser.add_argument('--topic', required=True, default="test/topic", help="Topic to publish messages to.")
parser.add_argument('--message', default="Hello World!", help="Message to publish. " +
"Specify empty string to publish nothing.")
# parse and load command-line parameter values
args = parser.parse_args()
# create and format values for HTTPS request
publish_url = 'https://' + args.endpoint + ':8443/topics/' + args.topic + '?qos=1'
publish_msg = args.message.encode('utf-8')
# make request
publish = requests.request('POST',
publish_url,
data=publish_msg,
cert=[args.cert, args.key])
# print results
print("Response status: ", str(publish.status_code))
if publish.status_code == 200:
print("Response body:", publish.text)