diff options
Diffstat (limited to 'ms/py-executor/resource_resolution/README')
| -rw-r--r-- | ms/py-executor/resource_resolution/README | 143 |
1 files changed, 0 insertions, 143 deletions
diff --git a/ms/py-executor/resource_resolution/README b/ms/py-executor/resource_resolution/README deleted file mode 100644 index 353600445..000000000 --- a/ms/py-executor/resource_resolution/README +++ /dev/null @@ -1,143 +0,0 @@ -# Resource resolution client - -## How to use examples - -### Insecure channel - -``` -from proto.BluePrintCommon_pb2_grpc import ActionIdentifiers, CommonHeader -from proto.BluePrintProcessing_pb2_grpc import ExecutionServiceInput -from resource_resolution.client import Client as ResourceResolutionClient - - -def generate_messages(): - commonHeader = CommonHeader() - commonHeader.requestId = "1234" - commonHeader.subRequestId = "1234-1" - commonHeader.originatorId = "CDS" - - actionIdentifiers = ActionIdentifiers() - actionIdentifiers.blueprintName = "sample-cba" - actionIdentifiers.blueprintVersion = "1.0.0" - actionIdentifiers.actionName = "SampleScript" - - input = ExecutionServiceInput(commonHeader=commonHeader, actionIdentifiers=actionIdentifiers) - - commonHeader2 = CommonHeader() - commonHeader2.requestId = "1235" - commonHeader2.subRequestId = "1234-2" - commonHeader2.originatorId = "CDS" - - input2 = ExecutionServiceInput(commonHeader=commonHeader2, actionIdentifiers=actionIdentifiers) - - yield from [input, input2] - - -if __name__ == "__main__": - with ResourceResolutionClient("localhost:50052") as client: - for response in client.process(generate_messages()): - print(response) - -``` - -### Secure channel - -``` -from proto.BluePrintCommon_pb2_grpc import ActionIdentifiers, CommonHeader -from proto.BluePrintProcessing_pb2_grpc import ExecutionServiceInput -from resource_resolution.client import Client as ResourceResolutionClient - - -def generate_messages(): - commonHeader = CommonHeader() - commonHeader.requestId = "1234" - commonHeader.subRequestId = "1234-1" - commonHeader.originatorId = "CDS" - - actionIdentifiers = ActionIdentifiers() - actionIdentifiers.blueprintName = "sample-cba" - actionIdentifiers.blueprintVersion = "1.0.0" - actionIdentifiers.actionName = "SampleScript" - - input = ExecutionServiceInput(commonHeader=commonHeader, actionIdentifiers=actionIdentifiers) - - commonHeader2 = CommonHeader() - commonHeader2.requestId = "1235" - commonHeader2.subRequestId = "1234-2" - commonHeader2.originatorId = "CDS" - - input2 = ExecutionServiceInput(commonHeader=commonHeader2, actionIdentifiers=actionIdentifiers) - - yield from [input, input2] - - -if __name__ == "__main__": - with open("certs/py-executor/py-executor-chain.pem", "rb") as f: - with ResourceResolutionClient("localhost:50052", use_ssl=True, root_certificates=f.read()) as client: - for response in client.process(generate_messages()): - print(response) - -``` - -### Authorizarion header - -``` -from proto.BluePrintCommon_pb2 import ActionIdentifiers, CommonHeader -from proto.BluePrintProcessing_pb2 import ExecutionServiceInput -from resource_resolution.client import Client as ResourceResolutionClient - - -def generate_messages(): - commonHeader = CommonHeader() - commonHeader.requestId = "1234" - commonHeader.subRequestId = "1234-1" - commonHeader.originatorId = "CDS" - - actionIdentifiers = ActionIdentifiers() - actionIdentifiers.blueprintName = "sample-cba" - actionIdentifiers.blueprintVersion = "1.0.0" - actionIdentifiers.actionName = "SampleScript" - - input = ExecutionServiceInput(commonHeader=commonHeader, actionIdentifiers=actionIdentifiers) - - commonHeader2 = CommonHeader() - commonHeader2.requestId = "1235" - commonHeader2.subRequestId = "1234-2" - commonHeader2.originatorId = "CDS" - - input2 = ExecutionServiceInput(commonHeader=commonHeader2, actionIdentifiers=actionIdentifiers) - - yield from [input, input2] - - -if __name__ == "__main__": - with ResourceResolutionClient("127.0.0.1:9111", use_header_auth=True, header_auth_token="Token test") as client: - for response in client.process(generate_messages()): - print(response) - -``` - -# ResourceResoulution helper class - -## How to use examples - -### Insecure channel - -``` -from resource_resolution.resource_resolution import ResourceResolution, WorkflowExecution, WorkflowExecutionResult - - -if __name__ == "__main__": - with ResourceResolution(use_header_auth=True, header_auth_token="Basic token") as rr: - for response in rr.execute_workflows( # type: WorkflowExecutionResult - WorkflowExecution( - blueprint_name="blueprintName", - blueprint_version="1.0", - workflow_name="resource-assignment" - ) - ): - if response.has_error: - print(response.error_message) - else: - print(response.payload) -```
\ No newline at end of file |