OpenShift での AMQ Online の評価

手順

1. 右上にある プラス アイコン (+) をクリックします。YAML のインポートウィンドウが開きます。
2. 左上のドロップダウンメニューから、amq-online-infra プロジェクトを選択します。

3. 次のコードをコピーします。

   apiVersion: admin.enmasse.io/v1beta1
   kind: StandardInfraConfig
   metadata:
     name: default

   Copy to Clipboard Toggle word wrap
4. YAML のインポートウィンドウで、コピーしたコードを貼り付けて 作成 をクリックします。StandardInfraConfig の概要ページが表示されます。
5. Operators > Installed Operators の順にクリックします。
6. AMQ Online Operator をクリックし、Standard Infra Config タブをクリックして、Status が Active と表示されていることを確認します。

手順

1. 右上にある プラス アイコン (+) をクリックします。YAML のインポートウィンドウが開きます。
2. 左上のドロップダウンメニューから、amq-online-infra プロジェクトを選択します。

3. 次のコードをコピーします。

   apiVersion: admin.enmasse.io/v1beta1
   kind: AuthenticationService
   metadata:
     name: standard-authservice
   spec:
     type: standard

   Copy to Clipboard Toggle word wrap
4. YAML のインポートウィンドウで、コピーしたコードを貼り付けて 作成 をクリックします。AuthenticationService の概要ページが表示されます。
5. Workloads > Pods をクリックします。カスタムリソースがデプロイされると、Readiness 列の Pod ステータスは Ready になります。

手順

1. 右上にある プラス アイコン (+) をクリックします。YAML のインポートウィンドウが開きます。
2. 左上のドロップダウンメニューから、amq-online-infra プロジェクトを選択します。

3. 次のコードをコピーします。

   apiVersion: admin.enmasse.io/v1beta2
   kind: AddressSpacePlan
   metadata:
     name: standard-small
   spec:
     addressSpaceType: standard
     infraConfigRef: default
     addressPlans:
       - standard-small-queue
     resourceLimits:
       router: 2.0
       broker: 3.0
       aggregate: 4.0

   Copy to Clipboard Toggle word wrap
4. YAML のインポートウィンドウで、コピーしたコードを貼り付けて 作成 をクリックします。AddressSpacePlan の概要ページが表示されます。
5. Operators > Installed Operators の順にクリックします。
6. AMQ Online Operator をクリックし、Address Space Plan タブをクリックして、Status が Active と表示されていることを確認します。

手順

1. 右上にある プラス アイコン (+) をクリックします。YAML のインポートウィンドウが開きます。
2. 左上のドロップダウンメニューから、amq-online-infra プロジェクトを選択します。

3. 次のコードをコピーします。

   apiVersion: admin.enmasse.io/v1beta2
   kind: AddressPlan
   metadata:
     name: standard-small-queue
   spec:
     addressType: queue
     resources:
       router: 0.01
       broker: 0.1

   Copy to Clipboard Toggle word wrap
4. YAML のインポートウィンドウで、コピーしたコードを貼り付けて 作成 をクリックします。AddressPlan の概要ページが表示されます。
5. Operators > Installed Operators の順にクリックします。
6. AMQ Online Operator をクリックし、Address Plan タブをクリックして、Status が Active と表示されていることを確認します。

手順

1. デバイスレジストリーホストをエクスポートします。

   export REGISTRY_HOST=$(oc -n amq-online-infra get routes device-registry --template='{{ .spec.host }}')

   Copy to Clipboard Toggle word wrap

2. デバイスレジストリーアクセストークンをエクスポートします。

   export TOKEN=$(oc whoami --show-token)

   Copy to Clipboard Toggle word wrap

   このトークンは、デバイスレジストリー管理 API に対する認証に使用されます。

3. 定義された ID でデバイスを登録します (この例では 4711 を使用します)。

   curl --insecure -X POST -i -H 'Content-Type: application/json' -H "Authorization: Bearer ${TOKEN}" https://$REGISTRY_HOST/v1/devices/myapp.iot/4711

   Copy to Clipboard Toggle word wrap

4. (オプション) 追加の登録情報を指定する必要がある場合は、次のように行います。

   curl --insecure -X POST -i -H 'Content-Type: application/json' -H "Authorization: Bearer ${TOKEN}" --data-binary '{
   	"via": ["gateway1"]
   }' https://$REGISTRY_HOST/v1/devices/myapp.iot/4711

   Copy to Clipboard Toggle word wrap

手順

1. デバイスの認証情報を追加します。

   curl --insecure -X PUT -i -H 'Content-Type: application/json' -H "Authorization: Bearer ${TOKEN}" --data-binary '[{
   	"type": "hashed-password",
   	"auth-id": "sensor1",
   	"secrets": [{
   		"pwd-plain":"'hono-secret'"
   	}]
   }]' https://$REGISTRY_HOST/v1/credentials/myapp.iot/4711

   Copy to Clipboard Toggle word wrap

手順

1. 管理者ユーザーを使用してデータベースインスタンスに接続します。
2. SQL スキーマ templates/iot/examples/postgresql/create.sql を確認してデプロイします。

手順

1. default という名前の IoTConfig インスタンスを編集します。

   oc edit iotconfig default

   Copy to Clipboard Toggle word wrap

2. ロギングオプションを設定し、保存してエディターを終了します。

   apiVersion: iot.enmasse.io/v1alpha1
   kind: IoTConfig
   metadata:
     namespace: enmasse-infra
     name: default
   spec:
     logging:
       level: info 

   1

   
       loggers: 

   2

   
         io.enmasse: debug 

   3

   
         io.netty: error 

   4

   Copy to Clipboard Toggle word wrap

   1

   デフォルトのグローバルログレベル。省略した場合は、info が使用されます。

   2

   ログチャネル固有のエントリーのセクション。

   3

   チャネル io.enmasse 内のメッセージのフィルタリングを debug レベルに下げます。

   4

   チャネル io.netty 内のメッセージのフィルタリングを error レベルに上げます。

3. Operator はロギング設定を適用し、必要なすべてのコンポーネントを再デプロイします。

手順

1. default という名前の IoTConfig インスタンスを編集します。

   oc edit iotconfig default

   Copy to Clipboard Toggle word wrap

2. ロギングオプションを設定し、保存してエディターを終了します。

   apiVersion: iot.enmasse.io/v1alpha1
   kind: IoTConfig
   metadata:
     namespace: enmasse-infra
     name: default
   spec:
     adapters:
       mqtt:
         containers:
           adapter:
             logback:
               level: info 

   1

   
               loggers: 

   2

   
                 io.enmasse: debug 

   3

   
                 io.netty: error 

   4

   Copy to Clipboard Toggle word wrap

   1

   アプリケーションのグローバルログレベル。省略した場合には、デフォルトのグローバルレベルが使用されます。

   2

   ログチャネル固有のエントリーのセクション。省略され、アプリケーションのグローバルログレベルも省略された場合には、インフラストラクチャーの既定のログチャネル設定が使用されます。アプリケーショングローバルログレベルが設定されている場合には、それは空のセットと見なされ、ログチャネル固有の設定は適用されません。

   3

   チャネル io.enmasse 内のメッセージのフィルタリングを debug レベルに下げます。

   4

   チャネル io.netty 内のメッセージのフィルタリングを error レベルに上げます。

3. Operator はロギング設定を適用し、必要なすべてのコンポーネントを再デプロイします。

手順

1. oc ツールを使用して、プロジェクトが終了状態でスタックしているかどうかを評価します。

   oc get iotproject iot -n myapp
   NAME   IOT TENANT  DOWNSTREAM HOST                       DOWNSTREAM PORT   TLS    PHASE
   iot    myapp.iot   messaging-be482a6.enmasse-infra.svc   5671              true   Terminating

   Copy to Clipboard Toggle word wrap

   出力には、終了中の状態のプロジェクトが表示されます。さらに、クリーンアップファイナライザーがまだ存在することを確認します。

   oc get iotproject iot -n myapp -ojsonpath='{range .metadata.finalizers[*]}{..}{"\n"}{end}'
   iot.enmasse.io/deviceRegistryCleanup

   Copy to Clipboard Toggle word wrap

   リストに iot.enmasse.io/deviceRegistryCleanup のエントリーが含まれている場合には、リソースのクリーンアッププロセスはまだ保留中です。

2. ファイナライザーのリストからファイナライザー iot.enmasse.io/deviceRegistryCleanup を手動で削除します。

   oc edit iotproject iot -n myapp

   Copy to Clipboard Toggle word wrap

   これにより、リソースのコンテンツを含むテキストエディターが開きます。

   apiVersion: iot.enmasse.io/v1alpha1
   kind: IoTProject
   metadata:
     creationTimestamp: "2019-12-09T15:00:00Z"
     deletionTimestamp: "2019-12-09T16:00:00Z"
     finalizers:
     - iot.enmasse.io/deviceRegistryCleanup 

   1

   
     name: iot
     namespace: myapp

   Copy to Clipboard Toggle word wrap

   1

   削除するファイナライザーのある行

   ファイナライザーの行を削除します。エディターを保存し、終了します。これにより、サーバーで自動的に更新がトリガーされ、システムは引き続き IoTProject リソースを削除します。

3. ファイナライザーを削除すると、リソースは削除され、システムから表示されなくなっているはずです。

手順

1. 現在のユーザーのトークンを抽出します。

   oc whoami -t

   Copy to Clipboard Toggle word wrap

手順

1. 新規のサービスアカウントを作成します。

   apiVersion: v1
   kind: ServiceAccount
   metadata:
     name: my-device-manager-account 

   1

   Copy to Clipboard Toggle word wrap

   1

   サービスアカウントの名前

2. IoTProject へのアクセスを許可する新しいロールを作成します。

   apiVersion: rbac.authorization.k8s.io/v1
   kind: Role
   metadata:
     name: device-manager-role 

   1

   
   rules: 

   2

   
   - apiGroups: ["iot.enmasse.io"]
     resources: ["iotprojects"]
     verbs: ["create", "update", "get", "list", "delete"]

   Copy to Clipboard Toggle word wrap

   1

   ロールの名前。

   2

   IoTProject への CRUD アクセスを許可する必要があるアクセスルール。

   この例では、namespace 内のすべての IoTProjects へのアクセスを許可します。アクセスをさらに制限するには、より具体的なルールを使用します。

3. 新しいロールバインディングを作成し、ロールをサービスアカウントに割り当てます。

   apiVersion: rbac.authorization.k8s.io/v1
   kind: RoleBinding
   metadata:
     name: my-device-manager-account-role-binding
   roleRef:
     apiGroup: rbac.authorization.k8s.io
     kind: Role
     name: device-manager-role 

   1

   
   subjects:
   - kind: ServiceAccount
     name: my-device-manager-account 

   2

   Copy to Clipboard Toggle word wrap

   1

   ロールの名前。

   2

   サービスアカウントの名前

4. サービスアカウントからトークンを取得します。

   oc serviceaccounts get-token my-device-manager-account

   Copy to Clipboard Toggle word wrap

手順

1. デバイスレジストリーホストをエクスポートします。

   export REGISTRY_HOST=$(oc -n amq-online-infra get routes device-registry --template='{{ .spec.host }}')

   Copy to Clipboard Toggle word wrap

2. デバイスレジストリーアクセストークンをエクスポートします。

   export TOKEN=$(oc whoami --show-token)

   Copy to Clipboard Toggle word wrap

   このトークンは、デバイスレジストリー管理 API に対する認証に使用されます。

3. 定義された ID でデバイスを登録します (この例では 4711 を使用します)。

   curl --insecure -X POST -i -H 'Content-Type: application/json' -H "Authorization: Bearer ${TOKEN}" https://$REGISTRY_HOST/v1/devices/myapp.iot/4711

   Copy to Clipboard Toggle word wrap

4. (オプション) 追加の登録情報を指定する必要がある場合は、次のように行います。

   curl --insecure -X POST -i -H 'Content-Type: application/json' -H "Authorization: Bearer ${TOKEN}" --data-binary '{
   	"via": ["gateway1"]
   }' https://$REGISTRY_HOST/v1/devices/myapp.iot/4711

   Copy to Clipboard Toggle word wrap

手順

1. デバイスの認証情報を追加します。

   curl --insecure -X PUT -i -H 'Content-Type: application/json' -H "Authorization: Bearer ${TOKEN}" --data-binary '[{
   	"type": "hashed-password",
   	"auth-id": "sensor1",
   	"secrets": [{
   		"pwd-plain":"'hono-secret'"
   	}]
   }]' https://$REGISTRY_HOST/v1/credentials/myapp.iot/4711

   Copy to Clipboard Toggle word wrap

手順

1. HTTP プロトコルを使用して telemetry を送信します。

   curl --insecure -X POST -i -u sensor1@myapp.iot:hono-secret -H 'Content-Type: application/json' --data-binary '{"temp": 5}' https://$(oc -n amq-online-infra get routes iot-http-adapter --template='{{ .spec.host }}')/telemetry

   Copy to Clipboard Toggle word wrap

手順

1. HTTP プロトコルを使用してイベントを送信します。

   curl --insecure -X POST -i -u sensor1@myapp.iot:hono-secret -H 'Content-Type: application/json' --data-binary '{"temp": 5}' https://$(oc -n amq-online-infra get routes iot-http-adapter --template='{{ .spec.host }}')/events

   Copy to Clipboard Toggle word wrap

手順

1. クライアントがコマンドを待機する時間を示す hono-ttd パラメーターを指定し、HTTP プロトコルを使用して Telemetry メッセージを送信します。

   curl --insecure -X POST -i -u sensor1@myapp.iot:hono-secret -H 'Content-Type: application/json' --data-binary '{"temp": 5}' https://$(oc -n amq-online-infra get routes iot-http-adapter --template='{{ .spec.host }}')/telemetry?hono-ttd=600

   Copy to Clipboard Toggle word wrap

2. カスタマーアプリケーションを実行して、ID が 4711 のデバイスにコマンドを送信します。

   java -jar hono-cli-*-exec.jar --hono.client.host=$MESSAGING_HOST --hono.client.port=$MESSAGING_PORT --hono.client.username=consumer --hono.client.password=foobar --tenant.id=myapp.iot --hono.client.trustStorePath=tls.crt --device.id=4711 --spring.profiles.active=command

   Copy to Clipboard Toggle word wrap

3. コマンドの名前、ペイロード、およびコンテンツタイプを入力するための指示に従います。以下に例を示します。

   >>>>>>>>> Enter name of command for device [4711] in tenant [myapp.iot] (prefix with 'ow:' to send one-way command):
   ow:setVolume
   >>>>>>>>> Enter command payload:
   {"level": 50}
   >>>>>>>>> Enter content type:
   application/json
   
   INFO  org.eclipse.hono.cli.app.Commander - Command sent to device

   Copy to Clipboard Toggle word wrap

   クライアントは HTTP 応答でコマンドを受け取ります。

   HTTP/1.1 200 OK
   hono-command: setVolume
   content-type: application/json
   content-length: 13
   
   {"level": 50}

   Copy to Clipboard Toggle word wrap

手順

1. MQTT プロトコルを使用してテレメトリーを送信します。

   mosquitto_pub -d -h $(oc -n amq-online-infra get routes iot-mqtt-adapter --template='{{ .spec.host }}') -p 443 -u 'sensor1@myapp.iot' -P hono-secret -t telemetry -m '{"temp": 5}' -i 4711 --cafile install/components/iot/examples/k8s-tls/build/iot-mqtt-adapter-fullchain.pem

   Copy to Clipboard Toggle word wrap

手順

1. MQTT プロトコルを使用してイベントを送信します。

   mosquitto_pub -d -h $(oc -n amq-online-infra get routes iot-mqtt-adapter --template='{{ .spec.host }}') -p 443 -u 'sensor1@myapp.iot' -P hono-secret -t events -m '{"temp": 5}' -i 4711 --cafile install/components/iot/examples/k8s-tls/build/iot-mqtt-adapter-fullchain.pem

   Copy to Clipboard Toggle word wrap

手順

1. MQTT クライアントを使用して、コマンドを受信するために MQTT トピックにサブスクライブします。

   mosquitto_sub -v -d -h $(oc -n amq-online-infra get routes iot-mqtt-adapter --template='{{ .spec.host }}') -p 443 -u 'sensor1@myapp.iot' -P hono-secret -t command/+/+/req/# -i 4711 --cafile install/components/iot/examples/k8s-tls/build/iot-mqtt-adapter-fullchain.pem

   Copy to Clipboard Toggle word wrap

2. カスタマーアプリケーションを実行して、ID が 4711 のデバイスにコマンドを送信します。

   java -jar hono-cli-*-exec.jar --hono.client.host=$MESSAGING_HOST --hono.client.port=$MESSAGING_PORT --hono.client.username=consumer --hono.client.password=foobar --tenant.id=myapp.iot --hono.client.trustStorePath=tls.crt --device.id=4711 --spring.profiles.active=command

   Copy to Clipboard Toggle word wrap

3. コマンドの名前、ペイロード、およびコンテンツタイプを入力するための指示に従います。以下に例を示します。

   >>>>>>>>> Enter name of command for device [4711] in tenant [myapp.iot] (prefix with 'ow:' to send one-way command):
   ow:setVolume
   >>>>>>>>> Enter command payload:
   {"level": 50}
   >>>>>>>>> Enter content type:
   application/json
   
   INFO  org.eclipse.hono.cli.app.Commander - Command sent to device

   Copy to Clipboard Toggle word wrap

   クライアントは MQTT メッセージでコマンドを受け取ります。

   Client 4711 received PUBLISH (d0, q0, r0, m0, 'command///req//setVolume', ... (13 bytes))
   command///req//setVolume {"level": 50}

   Copy to Clipboard Toggle word wrap

手順

1. 新しいデバイスを登録します。

   この手順のステップ 3 で、sigfox-backend を ID として指定します。

2. このデバイスの パスワード認証情報を設定します (例: sigfox-user/sigfox-password)。

手順

1. 登録する Sigfox デバイスの デバイス ID を見つけます。この ID は、Sigfox バックエンドでの登録プロセスの一部として取得します。

2. 新しいデバイスを登録します。

   デバイス ID を名前として指定し (例: 1AB2C3)、登録情報の一部として via フィールドにゲートウェイデバイスの名前を指定します (例 : {"via": "sigfox-backend"})。

手順

1. https://backend.sigfox.com にログインします。
2. Device Type でタイプを開いて編集し、Callbacks セクションに切り替えます。

3. 次の設定で、新しいカスタムコールバックを作成します。

   タイプ

   DATA – UPLINK

   チャネル

   URL

   URL パターン

   URL パターン。例: https://iot-sigfox-adapter.my.cluster/data/telemetry/<TENANT>?device={device}&data={data}

   HTTP メソッドの使用

   GET

   ヘッダー

   Authorization – Basic…

   SNI の送信

   ☑ (有効)

手順

1. https://backend.sigfox.com にログインします。
2. Device Type で、タイプを開いて編集し、Callbacks セクションに切り替えます。

3. コマンドアンドコントロールを有効にするコールバック設定を編集します。

   タイプ

   DATA – BIDIR への切り替え

   URL パターン

   ack パラメーターを追加します。例: https://iot-sigfox-adapter.my.cluster/data/telemetry/<TENANT>?device={device}&data={data} &ack={ack}