在開通服務時,系統會自動建立一個使用者管道。您可以通過一系列介面管理管道(pipeline)。例如:SearchPipeline、QueryPipelineList、UpdatePipeline。
搜尋管道
可以直接通過
SearchPipeline介面搜尋管道資訊。
import json
from aliyunsdkmts.request.v20140618 import SearchPipelineRequest
from aliyunsdkcore import client
region = '<region>'
access_key_id = '<access_key_id>'
access_key_secret = '<access_key_secret>'
client = client.AcsClient(access_key_id, access_key_secret, region)
request = SearchPipelineRequest.SearchPipelineRequest()
response = client.do_action_with_exception(request);
json_response = json.loads(response)
pipelines = json_response['PipelineList']['Pipeline']
for pipeline in pipelines:
print 'pipeline id:' + pipeline['Id'] + ', name:' + pipeline['Name'] + ', state:' + pipeline['State']
查詢管道
如果已經知道pipelineId,可以通過pipelineId調用
QueryPipelineList介面查詢管道資訊。
import json
from aliyunsdkmts.request.v20140618 import QueryPipelineListRequest
from aliyunsdkcore import client
region = '<region>'
access_key_id = '<access_key_id>'
access_key_secret = '<access_key_secret>'
pipeline_id = '<pipeline_id>'
client = client.AcsClient(access_key_id, access_key_secret, region)
request = QueryPipelineListRequest.QueryPipelineListRequest()
request.set_PipelineIds(pipeline_id)
response = client.do_action_with_exception(request);
json_response = json.loads(response)
pipelines = json_response['PipelineList']['Pipeline']
for pipeline in pipelines:
print 'pipeline id:' + pipeline['Id'] + ', name:' + pipeline['Name'] + ', state:' + pipeline['State']
更新管道
通過
UpdatePipeline更新管道資訊,包括更新管道名稱,狀態。管道的狀態包括Active、Paused。
import json
from aliyunsdkmts.request.v20140618 import SearchPipelineRequest
from aliyunsdkmts.request.v20140618 import UpdatePipelineRequest
from aliyunsdkcore import client
region = '<region>'
access_key_id = '<access_key_id>'
access_key_secret = '<access_key_secret>'
client = client.AcsClient(access_key_id, access_key_secret, region)
request = SearchPipelineRequest.SearchPipelineRequest()
response = client.do_action_with_exception(request);
json_response = json.loads(response)
pipeline = json_response['PipelineList']['Pipeline'][0]
request = UpdatePipelineRequest.UpdatePipelineRequest()
request.set_PipelineId(pipeline['Id'])
request.set_Name(pipeline['Name'])
request.set_State('Paused' if pipeline['State'] == 'Active' else 'Active')
response = client.do_action_with_exception(request);
json_response = json.loads(response)
pipeline = json_response['Pipeline']
print 'pipeline id:' + pipeline['Id'] + ', name:' + pipeline['Name'] + ', state:' + pipeline['State']