Blog Post: The versatility of gRPC

Author: buzzsurfr

.gitignore

@@ -14,7 +14,7 @@
 *.out
 
 # Dependency directories (remove the comment below to include it)
-# vendor/
+vendor/
 
 ##### VisualStudioCode #####
 
@@ -31,3 +31,9 @@
 ##### goreleaser #####
 
 dist/
+
+##### Python #####
+__pycache__/
+*.py[cod]
+*$py.class
+ 

README.md

@@ -6,6 +6,10 @@ gRPC examples and feature references
 
 * [helloworld](examples/helloworld/) - Forked from [grpc/grpc-go/examples/helloworld](https://github.com/grpc/grpc-go/tree/master/examples/helloworld)
 
+## Walkthroughs
+
+* [compute-options](walkthroughs/compute-options/) - Connect a greeter client written in Python running on a Lambda function to a greeter server written in Go running on a Fargate task (container). 
+
 ## Building examples
 
 This project uses [Task](https://taskfile.dev) to build and run examples. Each `Taskfile.yml` can be used to build and run each example or variation.

examples/helloworld/greeter_client_python/helloworld_pb2.py

@@ -0,0 +1,70 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+
+import helloworld_pb2 as helloworld__pb2
+
+
+class GreeterStub(object):
+    """The greeting service definition.
+    """
+
+    def __init__(self, channel):
+        """Constructor.
+
+        Args:
+            channel: A grpc.Channel.
+        """
+        self.SayHello = channel.unary_unary(
+                '/helloworld.Greeter/SayHello',
+                request_serializer=helloworld__pb2.HelloRequest.SerializeToString,
+                response_deserializer=helloworld__pb2.HelloReply.FromString,
+                )
+
+
+class GreeterServicer(object):
+    """The greeting service definition.
+    """
+
+    def SayHello(self, request, context):
+        """Sends a greeting
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+
+def add_GreeterServicer_to_server(servicer, server):
+    rpc_method_handlers = {
+            'SayHello': grpc.unary_unary_rpc_method_handler(
+                    servicer.SayHello,
+                    request_deserializer=helloworld__pb2.HelloRequest.FromString,
+                    response_serializer=helloworld__pb2.HelloReply.SerializeToString,
+            ),
+    }
+    generic_handler = grpc.method_handlers_generic_handler(
+            'helloworld.Greeter', rpc_method_handlers)
+    server.add_generic_rpc_handlers((generic_handler,))
+
+
+ # This class is part of an EXPERIMENTAL API.
+class Greeter(object):
+    """The greeting service definition.
+    """
+
+    @staticmethod
+    def SayHello(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/helloworld.Greeter/SayHello',
+            helloworld__pb2.HelloRequest.SerializeToString,
+            helloworld__pb2.HelloReply.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

examples/helloworld/greeter_client_python/helloworld_pb2_grpc.py

@@ -0,0 +1,37 @@
+# Copyright 2015 gRPC authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""The Python implementation of the GRPC helloworld.Greeter client."""
+
+from __future__ import print_function
+import logging
+import os
+import sys
+
+import grpc
+
+import helloworld_pb2
+import helloworld_pb2_grpc
+
+endpoint = os.getenv("GREETER_ENDPOINT", "localhost:50051")
+
+def handler(event, context):
+    with grpc.insecure_channel(endpoint) as channel:
+        stub = helloworld_pb2_grpc.GreeterStub(channel)
+        response = stub.SayHello(helloworld_pb2.HelloRequest(name=event['name']))
+    print("Received from backend: " + response.message)
+
+if __name__ == "__main__":
+    event = {}
+    event['name'] = " ".join(sys.argv[1:])
+    handler(event, None)

examples/helloworld/greeter_client_python/index.py

@@ -0,0 +1,2 @@
+grpcio==1.32.0
+protobuf==3.13.0

examples/helloworld/greeter_client_python/requirements.txt

@@ -0,0 +1,11 @@
+*.js
+!jest.config.js
+*.d.ts
+node_modules
+
+# CDK asset staging directory
+.cdk.staging
+cdk.out
+
+# Parcel default cache directory
+.parcel-cache

walkthroughs/compute-options/.gitignore

@@ -0,0 +1,6 @@
+*.ts
+!*.d.ts
+
+# CDK asset staging directory
+.cdk.staging
+cdk.out

walkthroughs/compute-options/.npmignore

@@ -0,0 +1,10 @@
+# Compute Options Walkthrough
+
+This is a CDK project that deploys a greeter client written in Python running on a Lambda function to a greeter server written in Go running on a Fargate task (container).
+
+This walkthrough is the code used in the AWS Open Source Blog post **The versatility of gRPC, an open source high-performance RPC framework** (link TBD).
+
+## Useful commands
+
+ * `npm run build && cdk deploy`   compile typescript to js and deploy this stack to your default AWS account/region
+ * `cdk destroy`       removes the deployed CloudFormation stack

walkthroughs/compute-options/README.md

@@ -0,0 +1,7 @@
+#!/usr/bin/env node
+import 'source-map-support/register';
+import * as cdk from '@aws-cdk/core';
+import { ComputeOptionsStack } from '../lib/compute-options-stack';
+
+const app = new cdk.App();
+new ComputeOptionsStack(app, 'ComputeOptionsStack');

walkthroughs/compute-options/bin/compute-options.ts

@@ -0,0 +1,8 @@
+{
+  "app": "npx ts-node bin/compute-options.ts",
+  "context": {
+    "@aws-cdk/core:enableStackNameDuplicates": "true",
+    "aws-cdk:enableDiffNoFail": "true",
+    "@aws-cdk/core:stackRelativeExports": "true"
+  }
+}

walkthroughs/compute-options/cdk.json

@@ -0,0 +1,7 @@
+module.exports = {
+  roots: ['<rootDir>/test'],
+  testMatch: ['**/*.test.ts'],
+  transform: {
+    '^.+\\.tsx?$': 'ts-jest'
+  }
+};