Longhorn クラウド ネイティブ コンテナ分散ストレージ - Python クライアント

[[421320]]

この記事はWeChatの公開アカウント「Hacker Afternoon Tea」から転載したもので、著者はShaoです。この記事を転載する場合は、Hacker Afternoon Tea公式アカウントまでご連絡ください。

現在、Longhorn UI を使用して Longhorn を操作できます。それまでの間、以下に示すように Python を使用して Longhorn API にアクセスできます。

1. Longhorn APIエンドポイントを取得する

Longhorn と通信する 1 つの方法は、longhorn-frontend サービスを使用することです。

Longhornがインストールされている同じクラスタで自動化/スクリプトツールを実行している場合は、エンドポイントhttp://longhorn-frontend.longhorn-system/v1に接続します。

ローカル マシンで自動化/スクリプト ツールを実行している場合は、kubectl port-forward を使用して longhorn-frontend サービスを localhost に転送します。

 kubectl ポート転送サービス/longhorn-frontend 8080:http -n longhorn-system

エンドポイント http://localhost:8080/v1 に接続します。

2. Pythonクライアントの使用

longhorn.py ファイル (Python クライアントが含まれています) を次の Python スクリプトにインポートし、API エンドポイントからクライアントを作成します。

https://github.com/longhorn/longhorn-tests/blob/master/manager/integration/tests/longhorn.py

ロングホーンをインポートする
 
 # 自動化/スクリプトツールがLonghornがインストールされている同じクラスタ内にある場合
longhorn_url = 'http://longhorn-frontend.longhorn-system/v1'  
 # `longhorn-frontend` サービスをローカルホストに転送する場合
longhorn_url = 'http://localhost:8080/v1'   
 
クライアント = longhorn.Client(url=longhorn_url) 
 
 # ボリューム操作
#すべてのボリュームを一覧表示する
ボリューム = client.list_volume()
 # ボリュームを取得する 名前/ID
 testvol1 = client.by_id_volume(id= "testvol1" )
 # TESTVOL1を添付
testvol1 = testvol1.attach(hostId= "worker-1" )
 # TESTVOL1を切り離す
testvol1.デタッチ()
 # TESTVOL1のスナップショットを作成します 名前 
スナップショット1 = testvol1.snapshotCreate( name = "スナップショット1" )
 #スナップショットからバックアップを作成するNAME  
 testvol1.snapshotBackup( name = snapshot1.name )
 # TESTVOL1のレプリカ数を更新します
testvol1.レプリカ数を更新(レプリカ数=2)
 # Longhorn 統合テストのその他の例については、https://github.com/longhorn/longhorn-tests/tree/master/manager/integration/tests を参照してください。 
 
 # ノード操作
#すべてのノードを一覧表示する
ノード = client.list_node()
 # ノードを取得する 名前/ID
 node1 = client.by_id_node(id= "ワーカー-1" )
 # NODE1のスケジュールを無効にする
クライアント。更新(node1、allowScheduling= False )
 # NODE1のスケジュールを有効にする
クライアント。更新(node1、allowScheduling= True )
 # Longhorn 統合テストのその他の例については、https://github.com/longhorn/longhorn-tests/tree/master/manager/integration/tests を参照してください。 
 
 # 設定操作
#すべての設定を一覧表示する
設定 = client.list_setting()
 # 設定を取得する 名前/ID
バックアップターゲット設定 = client.by_id_setting(id= "バックアップターゲット" )
 #設定を更新する
バックアップターゲット設定 = クライアント。更新(backupTargetsetting、値 = "s3://backupbucket@us-east-1/" )
 # Longhorn 統合テストのその他の例については、https://github.com/longhorn/longhorn-tests/tree/master/manager/integration/tests を参照してください。