第3章 AMQ Online のモノのインターネット (IoT)

手順

1. cluster-admin 権限を持つユーザーとしてログインしてます。

   oc login -u system:admin

   Copy to Clipboard Toggle word wrap

2. (オプション) amq-online-infra 以外のプロジェクトにデプロイする場合は、次のコマンドを実行し、後続の手順で amq-online-infra を置き換える必要があります。

   sed -i 's/amq-online-infra/my-project/' install/bundles/amq-online/*.yaml

   Copy to Clipboard Toggle word wrap

3. AMQ Online をデプロイするプロジェクトを作成します。

   oc new-project amq-online-infra

   Copy to Clipboard Toggle word wrap
4. ダウンロードしたリリースファイルの場所にディレクトリーを変更します。

5. amq-online バンドルを使用してデプロイします。

   oc apply -f install/bundles/amq-online

   Copy to Clipboard Toggle word wrap

6. (オプション) サンプルプランとインフラストラクチャー設定をインストールします。

   oc apply -f install/components/example-plans

   Copy to Clipboard Toggle word wrap

7. (オプション) サンプルのロールをインストールします。

   oc apply -f install/components/example-roles

   Copy to Clipboard Toggle word wrap

8. (オプション) 標準 認証サービスをインストールします。

   oc apply -f install/components/example-authservices/standard-authservice.yaml

   Copy to Clipboard Toggle word wrap

9. (オプション) Service Catalog 統合をインストールします。

   oc apply -f install/components/service-broker
   oc apply -f install/components/cluster-service-broker

   Copy to Clipboard Toggle word wrap

手順

1. (オプション) amq-online-infra 以外のプロジェクトにデプロイする場合は、次のコマンドを実行し、後続の手順で amq-online-infra を置き換える必要があります。

   sed -i 's/amq-online-infra/my-project/' install/preview-bundles/iot/*.yaml

   Copy to Clipboard Toggle word wrap

2. IoT バンドルをデプロイします。

   oc apply -f install/preview-bundles/iot

   Copy to Clipboard Toggle word wrap

3. MQTT プロトコルアダプターの証明書を作成します。テスト目的で、自己署名証明書を作成できます。

   ./install/components/iot/examples/k8s-tls/create
   oc create secret tls iot-mqtt-adapter-tls --key=install/components/iot/examples/k8s-tls/build/iot-mqtt-adapter-key.pem --cert=install/components/iot/examples/k8s-tls/build/iot-mqtt-adapter-fullchain.pem

   Copy to Clipboard Toggle word wrap

   スクリプトを呼び出すときに環境変数 NAMESPACE を設定して、deploy スクリプトがキーと証明書をインストールする namespace をオーバーライドできます。以下に例を示します。

   NAMESPACE=my-namespace ./install/components/iot/examples/k8s-tls/deploy

   Copy to Clipboard Toggle word wrap
   注記

   クラスターが localhost で実行されていない場合には、外部クライアント (MQTT など) が適切なサービスに適切に接続できるように、証明書を作成するときにクラスターのホスト名を指定する必要があります。以下に例を示します。

   CLUSTER=x.x.x.x.nip.io install/components/iot/examples/k8s-tls/create

   Copy to Clipboard Toggle word wrap

4. (オプション) PostgreSQL サーバーをインストールし、データベースを作成します。

   oc apply -f install/components/iot/examples/postgresql/deploy

   Copy to Clipboard Toggle word wrap

   すでに PostgreSQL インスタンスがあり、それにアクセスするユーザーでデータベースを作成した場合は、この手順を省略できます。

5. データベーススキーマを適用します。

   作成したデータベースインスタンスで次の SQL ファイルを実行する必要があります。設定によっては、データベース管理者権限が必要になる場合があります。

   • install/components/iot/examples/postgresql/create.sql
   • install/components/iot/examples/postgresql/create.devcon.sql

   データベースに接続された psql コマンドを使用して、SQL ファイルを実行できます。以下は、前の手順で説明したように PostgreSQL をインストールしたときに、コンテナー内から psql を実行する方法の例を示しています。

   oc exec -ti deployment/postgresql -- bash -c "PGPASSWORD=user12 psql device-registry registry" < install/components/iot/examples/postgresql/create.sql
   oc exec -ti deployment/postgresql -- bash -c "PGPASSWORD=user12 psql device-registry registry" < install/components/iot/examples/postgresql/create.devcon.sql

   Copy to Clipboard Toggle word wrap

6. IoT インフラストラクチャー設定の例をインストールします。

   oc apply -f install/components/iot/examples/iot-config.yaml

   Copy to Clipboard Toggle word wrap

手順

1. メッセージングテナントとしてログインします。

   oc login -u developer

   Copy to Clipboard Toggle word wrap

2. 管理対象 IoT プロジェクトを作成します。

   oc new-project myapp
   oc create -f install/components/iot/examples/iot-project-managed.yaml

   Copy to Clipboard Toggle word wrap

3. リソースの準備が整うまで待ちます。

   oc get addressspace iot
   oc get iotproject iot

   Copy to Clipboard Toggle word wrap
   注記

   Phase フィールドに両方のリソースの Ready ステータスが表示されていることを確認します。

4. メッセージングコンシューマーユーザーを作成します。

   oc create -f install/components/iot/examples/iot-user.yaml

   Copy to Clipboard Toggle word wrap

手順

1. Eclipse Hono コマンドラインクライアント をダウンロードします。

2. メッセージングエンドポイント証明書を取得します。

   oc -n myapp get addressspace iot -o jsonpath={.status.caCert} | base64 --decode > tls.crt

   Copy to Clipboard Toggle word wrap

3. メッセージングエンドポイントのホストとポートをエクスポートします。

   export MESSAGING_HOST=$(oc get -n myapp addressspace iot -o jsonpath='{.status.endpointStatuses[?(@.name=="messaging")].externalHost}')
   export MESSAGING_PORT=443

   Copy to Clipboard Toggle word wrap

手順

1. 顧客アプリケーションを実行して、telemetry を受信します。

   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 --message.type=telemetry

   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