このトピックでは、Python 向けの ApsaraMQ for RocketMQ 5.x ソフトウェア開発キット (SDK) を使用してメッセージを送受信するためのサンプルコードを提供します。
メッセージタイプ | メッセージ送信のサンプルコード | メッセージサブスクライブのサンプルコード | |
なし | |||
なし | |||
パラメーター
パラメーター | 値の例 | 説明 |
endpoints | rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080 | ApsaraMQ for RocketMQ インスタンスのエンドポイントです。エンドポイントの取得方法については、「インスタンスエンドポイントの取得」をご参照ください。
|
InstanceId | rmq-cn-xxx | ApsaraMQ for RocketMQ インスタンスの ID。 |
topic | normal_test | メッセージの送信先、またはメッセージの消費元となる ApsaraMQ for RocketMQ インスタンスの Topic。 事前に ApsaraMQ for RocketMQ インスタンスで Topic を作成しておく必要があります。詳細については、「Topic の作成」をご参照ください。 |
consumer-group | GID_test | コンシューマーが ApsaraMQ for RocketMQ インスタンス内のメッセージを消費するために使用するコンシューマーグループ。 事前に ApsaraMQ for RocketMQ インスタンスでコンシューマーグループを作成しておく必要があります。詳細については、「コンシューマーグループの作成」をご参照ください。 |
ak | 1XVg0hzgKm****** | ApsaraMQ for RocketMQ インスタンスのユーザー名です。インターネット経由でインスタンスにアクセスする場合は、ユーザー名を指定する必要があります。VPC 内でインスタンスにアクセスする場合、インスタンスがサーバーレスインスタンスであり、かつ VPC 内での認証フリー機能が無効になっている場合にのみ、ユーザー名を指定する必要があります。 ユーザー名の取得方法については、「インスタンスのユーザー名とパスワードの取得」をご参照ください。 |
sk | ijSt8rEc45****** | ApsaraMQ for RocketMQ インスタンスのパスワードです。インターネット経由でインスタンスにアクセスする場合は、パスワードを指定する必要があります。VPC 内でインスタンスにアクセスする場合、インスタンスがサーバーレスインスタンスであり、かつ VPC 内での認証フリー機能が無効になっている場合にのみ、パスワードを指定する必要があります。 パスワードの取得方法については、「インスタンスのユーザー名とパスワードの取得」をご参照ください。 |
サーバーレスインスタンスのパブリックネットワークアクセス
サーバーレスの ApsaraMQ for RocketMQ インスタンスにパブリックネットワーク経由でアクセスするには、メッセージングコードに次の内容を追加します：
InstanceId を実際のインスタンス ID に置き換えてください。
config = ClientConfiguration(endpoints, credentials, "InstanceId")