Developing .NET Core AWS Lambda functions
This post is courtesy of Mark Easton, Senior Solutions Architect – AWS
One of the biggest benefits of Lambda functions is that they isolate you from the underlying infrastructure. While that makes it easy to deploy and manage your code, it’s critical to have a clearly defined approach for testing, debugging, and diagnosing problems.
There’s a variety of best practices and AWS services to help you out. When developing Lambda functions in .NET, you can follow a four-pronged approach:
- Unit testing to test and debug functional units in isolation
- Logging with Amazon CloudWatch to record events and errors
- Recording in AWS X-Ray to trace execution across services
This post demonstrates the approach by creating a simple Lambda function that can be called from a gateway created by Amazon API Gateway and which returns the current UTC time. The post shows you how to design your code to allow for easy debugging, logging and tracing.
If you haven’t created Lambda functions with .NET Core before, then the following posts can help you get started:
Unit testing Lambda functions
One of the easiest ways to create a .NET Core Lambda function is to use the .NET Core CLI and create a solution using the Lambda Empty Serverless template.
If you haven’t already installed the Lambda templates, run the following command:
dotnet new -i Amazon.Lambda.Templates::*
You can now use the template to create a serverless project and unit test project, and then add them to a .NET Core solution by running the following commands:
dotnet new serverless.EmptyServerless -n DebuggingExample
cd DebuggingExample
dotnet new sln -n DebuggingExample\
dotnet sln DebuggingExample.sln add */*/*.csproj
Although you haven’t added any code yet, you can validate that everything’s working by executing the unit tests. Run the following commands:
cd test/DebuggingExample.Tests/
dotnet test
One of the key principles to effective unit testing is ensuring that units of functionality can be tested in isolation. It’s good practice to de-couple the Lambda function’s actual business logic from the plumbing code that handles the actual Lambda requests.
Using your favorite editor, create a new file, ITimeProcessor.cs, in the src/DebuggingExample folder, and create the following basic interface:
using System;
namespace DebuggingExample
{
public interface ITimeProcessor
{
DateTime CurrentTimeUTC();
}
}
Then, create a new TimeProcessor.cs file in the src/DebuggingExample folder. The file contains a concrete class implementing the interface.
using System;
namespace DebuggingExample
{
public class TimeProcessor : ITimeProcessor
{
public DateTime CurrentTimeUTC()
{
return DateTime.UtcNow;
}
}
}
Now add a TimeProcessorTest.cs file to the src/DebuggingExample.Tests folder. The file should contain the following code:
using System;
using Xunit;
namespace DebuggingExample.Tests
{
public class TimeProcessorTest
{
[Fact]
public void TestCurrentTimeUTC()
{
// Arrange
var processor = new TimeProcessor();
var preTestTimeUtc = DateTime.UtcNow;
// Act
var result = processor.CurrentTimeUTC();
// Assert time moves forwards
var postTestTimeUtc = DateTime.UtcNow;
Assert.True(result >= preTestTimeUtc);
Assert.True(result <= postTestTimeUtc);
}
}
}
You can then execute all the tests. From the test/DebuggingExample.Tests folder, run the following command:
dotnet test
Surfacing business logic in a Lambda function
Now that you have your business logic written and tested, you can surface it as a Lambda function. Edit the src/DebuggingExample/Function.cs file so that it calls the CurrentTimeUTC method:
using System;
using System.Collections.Generic;
using System.Net;
using Amazon.Lambda.Core;
using Amazon.Lambda.APIGatewayEvents;
using Newtonsoft.Json;
// Assembly attribute to enable the Lambda function's JSON input to be converted into a .NET class.
[assembly: LambdaSerializer(
typeof(Amazon.Lambda.Serialization.Json.JsonSerializer))]
namespace DebuggingExample
{
public class Functions
{
ITimeProcessor processor = new TimeProcessor();
public APIGatewayProxyResponse Get(
APIGatewayProxyRequest request, ILambdaContext context)
{
var result = processor.CurrentTimeUTC();
return CreateResponse(result);
}
APIGatewayProxyResponse CreateResponse(DateTime? result)
{
int statusCode = (result != null) ?
(int)HttpStatusCode.OK :
(int)HttpStatusCode.InternalServerError;
string body = (result != null) ?
JsonConvert.SerializeObject(result) : string.Empty;
var response = new APIGatewayProxyResponse
{
StatusCode = statusCode,
Body = body,
Headers = new Dictionary<string, string>
{
{ "Content-Type", "application/json" },
{ "Access-Control-Allow-Origin", "*" }
}
};
return response;
}
}
}
First, an instance of the TimeProcessor class is instantiated, and a Get() method is then defined to act as the entry point to the Lambda function.
By default, .NET Core Lambda function handlers expect their input in a Stream. This can be overridden by declaring a customer serializer, and then defining the handler’s method signature using a custom request and response type.
Because the project was created using the serverless.EmptyServerless template, it already overrides the default behavior. It does this by including a using reference to Amazon.Lambda.APIGatewayEvents and then declaring a custom serializer. For more information about using custom serializers in .NET, see the AWS Lambda for .NET Core repository on GitHub.
Get() takes a couple of parameters:
- The APIGatewayProxyRequest parameter contains the request from the API Gateway fronting the Lambda function
- The optional ILambdaContext parameter contains details of the execution context.
The Get() method calls CurrentTimeUTC() to retrieve the time from the business logic.
Finally, the result from CurrentTimeUTC() is passed to the CreateResponse() method, which converts the result into an APIGatewayResponse object to be returned to the caller.
Because the updated Lambda function no longer passes the unit tests, update the TestGetMethod in test/DebuggingExample.Tests/FunctionTest.cs file. Update the test by removing the following line:
Assert.Equal("Hello AWS Serverless", response.Body);
This leaves your FunctionTest.cs file as follows:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Xunit;
using Amazon.Lambda.Core;
using Amazon.Lambda.TestUtilities;
using Amazon.Lambda.APIGatewayEvents;
using DebuggingExample;
namespace DebuggingExample.Tests
{
public class FunctionTest
{
public FunctionTest()
{
}
[Fact]
public void TetGetMethod()
{
TestLambdaContext context;
APIGatewayProxyRequest request;
APIGatewayProxyResponse response;
Functions functions = new Functions();
request = new APIGatewayProxyRequest();
context = new TestLambdaContext();
response = functions.Get(request, context);
Assert.Equal(200, response.StatusCode);
}
}
}
Again, you can check that everything is still working. From the test/DebuggingExample.Tests folder, run the following command:
dotnet test
Local integration testing with the AWS SAM CLI
Unit testing is a great start for testing thin slices of functionality. But to test that your API Gateway and Lambda function integrate with each other, you can test locally by using the AWS SAM CLI, installed as described in the AWS Lambda Developer Guide.
Unlike unit testing, which allows you to test functions in isolation outside of their runtime environment, the AWS SAM CLI executes your code in a locally hosted Docker container. It can also simulate a locally hosted API gateway proxy, allowing you to run component integration tests.
After you’ve installed the AWS SAM CLI, you can start using it by creating a template that describes your Lambda function by saving a file named template.yaml in the DebuggingExample directory with the following contents:
AWSTemplateFormatVersion: '2010-09-09'
Transform: AWS::Serverless-2016-10-31
Description: Sample SAM Template for DebuggingExample
# More info about Globals: https://github.com/awslabs/serverless-application-model/blob/master/docs/globals.rst
Globals:
Function:
Timeout: 10
Resources:
DebuggingExampleFunction:
Type: AWS::Serverless::Function # More info about Function Resource: https://github.com/awslabs/serverless-application-model/blob/master/versions/2016-10-31.md#awsserverlessfunction
Properties:
FunctionName: DebuggingExample
CodeUri: src/DebuggingExample/bin/Release/netcoreapp2.1/publish
Handler: DebuggingExample::DebuggingExample.Functions::Get
Runtime: dotnetcore2.1
Environment: # More info about Env Vars: https://github.com/awslabs/serverless-application-model/blob/master/versions/2016-10-31.md#environment-object
Variables:
PARAM1: VALUE
Events:
DebuggingExample:
Type: Api # More info about API Event Source: https://github.com/awslabs/serverless-application-model/blob/master/versions/2016-10-31.md#api
Properties:
Path: /
Method: get
Outputs:
DebuggingExampleApi:
Description: "API Gateway endpoint URL for Prod stage for Debugging Example function"
Value: !Sub "https://${ServerlessRestApi}.execute-api.${AWS::Region}.amazonaws.com/Prod/DebuggingExample/"
DebuggingExampleFunction:
Description: "Debugging Example Lambda Function ARN"
Value: !GetAtt DebuggingExampleFunction.Arn
DebuggingExampleFunctionIamRole:
Description: "Implicit IAM Role created for Debugging Example function"
Value: !GetAtt DebuggingExampleFunctionRole.Arn
Now that you have an AWS SAM CLI template, you can test your code locally. Because the Lambda function expects a request from API Gateway, create a sample API Gateway request. Run the following command:
sam local generate-event api > testApiRequest.json
You can now publish your DebuggingExample code locally and invoke it by passing in the sample request as follows:
dotnet publish -c Release
sam local invoke "DebuggingExampleFunction" --event testApiRequest.json
The first time that you run it, it might take some time to pull down the container image in which to host the Lambda function. After you’ve invoked it one time, the container image is cached locally, and execution speeds up.
Finally, rather than testing your function by sending it a sample request, test it with a real API gateway request by running API Gateway locally:
sam local start-api
If you now navigate to http://127.0.0.1:3000/ in your browser, you can get the API gateway to send a request to your locally hosted Lambda function. See the results in your browser.
Logging events with CloudWatch
Having a test strategy allows you to execute, test, and debug Lambda functions. After you’ve deployed your functions to AWS, you must still log what the functions are doing so that you can monitor their behavior.
The easiest way to add logging to your Lambda functions is to add code that writes events to CloudWatch. To do this, add a new method, LogMessage(), to the src/DebuggingExample/Function.cs file.
void LogMessage(ILambdaContext ctx, string msg)
{
ctx.Logger.LogLine(
string.Format("{0}:{1} - {2}",
ctx.AwsRequestId,
ctx.FunctionName,
msg));
}
This takes in the context object from the Lambda function’s Get() method, and sends a message to CloudWatch by calling the context object’s Logger.Logline() method.
You can now add calls to LogMessage in the Get() method to log events in CloudWatch. It’s also a good idea to add a Try… Catch… block to ensure that exceptions are logged as well.
public APIGatewayProxyResponse Get(APIGatewayProxyRequest request, ILambdaContext context)
{
LogMessage(context, "Processing request started");
APIGatewayProxyResponse response;
try
{
var result = processor.CurrentTimeUTC();
response = CreateResponse(result);
LogMessage(context, "Processing request succeeded.");
}
catch (Exception ex)
{
LogMessage(context, string.Format("Processing request failed - {0}", ex.Message));
response = CreateResponse(null);
}
return response;
}
To validate that the changes haven’t broken anything, you can now execute the unit tests again. Run the following commands:
cd test/DebuggingExample.Tests/
dotnet test
Tracing execution with X-Ray
Your code now logs events in CloudWatch, which provides a solid mechanism to help monitor and diagnose problems.
However, it can also be useful to trace your Lambda function’s execution to help diagnose performance or connectivity issues, especially if it’s called by or calling other services. X-Ray provides a variety of features to help analyze and trace code execution.
To enable active tracing on your function you need to modify the SAM template we created earlier to add a new attribute to the function resource definition. With SAM this is as easy as adding the Tracing attribute and specifying it as Active below the Timeout attribute in the Globals section of the template.yaml file:
Globals:
Function:
Timeout: 10
Tracing: Active
To call X-Ray from within your .NET Core code, you must add the AWSSDKXRayRecoder to your solution by running the following command in the src/DebuggingExample folder:
dotnet add package AWSXRayRecorder –-version 2.2.1-beta
Then, add the following using statement at the top of the src/DebuggingExample/Function.cs file:
using Amazon.XRay.Recorder.Core;
Add a new method to the Function class, which takes a function and name and then records an X-Ray subsegment to trace the execution of the function.
private T TraceFunction<T>(Func<T> func, string subSegmentName)
{
AWSXRayRecorder.Instance.BeginSubsegment(subSegmentName);
T result = func();
AWSXRayRecorder.Instance.EndSubsegment();
return result;
}
You can now update the Get() method by replacing the following line:
var result = processor.CurrentTimeUTC();
Replace it with this line:
var result = TraceFunction(processor.CurrentTimeUTC, "GetTime");
The final version of Function.cs, in all its glory, is now:
using System;
using System.Collections.Generic;
using System.Net;
using Amazon.Lambda.Core;
using Amazon.Lambda.APIGatewayEvents;
using Newtonsoft.Json;
using Amazon.XRay.Recorder.Core;
// Assembly attribute to enable the Lambda function's JSON input to be converted into a .NET class.
[assembly: LambdaSerializer(
typeof(Amazon.Lambda.Serialization.Json.JsonSerializer))]
namespace DebuggingExample
{
public class Functions
{
ITimeProcessor processor = new TimeProcessor();
public APIGatewayProxyResponse Get(APIGatewayProxyRequest request, ILambdaContext context)
{
LogMessage(context, "Processing request started");
APIGatewayProxyResponse response;
try
{
var result = TraceFunction(processor.CurrentTimeUTC, "GetTime");
response = CreateResponse(result);
LogMessage(context, "Processing request succeeded.");
}
catch (Exception ex)
{
LogMessage(context, string.Format("Processing request failed - {0}", ex.Message));
response = CreateResponse(null);
}
return response;
}
APIGatewayProxyResponse CreateResponse(DateTime? result)
{
int statusCode = (result != null) ?
(int)HttpStatusCode.OK :
(int)HttpStatusCode.InternalServerError;
string body = (result != null) ?
JsonConvert.SerializeObject(result) : string.Empty;
var response = new APIGatewayProxyResponse
{
StatusCode = statusCode,
Body = body,
Headers = new Dictionary<string, string>
{
{ "Content-Type", "application/json" },
{ "Access-Control-Allow-Origin", "*" }
}
};
return response;
}
private void LogMessage(ILambdaContext context, string message)
{
context.Logger.LogLine(string.Format("{0}:{1} - {2}", context.AwsRequestId, context.FunctionName, message));
}
private T TraceFunction<T>(Func<T> func, string actionName)
{
AWSXRayRecorder.Instance.BeginSubsegment(actionName);
T result = func();
AWSXRayRecorder.Instance.EndSubsegment();
return result;
}
}
}
Since AWS X-Ray requires an agent to collect trace information, if you want to test the code locally you should now install the AWS X-Ray agent. Once it’s installed, confirm the changes haven’t broken anything by running the unit tests again:
cd test/DebuggingExample.Tests/
dotnet test
For more information about using X-Ray from .NET Core, see the AWS X-Ray Developer Guide. For information about adding support for X-Ray in Visual Studio, see the New AWS X-Ray .NET Core Support post.
Deploying and testing the Lambda function remotely
Having created your Lambda function and tested it locally, you’re now ready to package and deploy your code.
First of all you need an Amazon S3 bucket to deploy the code into. If you don’t already have one, create a suitable S3 bucket.
You can now package the .NET Lambda Function and copy it to Amazon S3.
sam package \
--template-file template.yaml \
--output-template debugging-example.yaml \
--s3-bucket debugging-example-deploy
Finally, deploy the Lambda function by running the following command:
sam deploy \
--template-file debugging-example.yaml \
--stack-name DebuggingExample \
--capabilities CAPABILITY_IAM \
--region eu-west-1
After your code has deployed successfully, test it from your local machine by running the following command:
dotnet lambda invoke-function DebuggingExample -–region eu-west-1
Diagnosing the Lambda function
Having run the Lambda function, you can now monitor its behavior by logging in to the AWS Management Console and then navigating to CloudWatch Logs.
You can now click on the /aws/lambda/DebuggingExample log group to view all the recorded log streams for your Lambda function.
If you open one of the log streams, you see the various messages recorded for the Lambda function, including the two events explicitly logged from within the Get() method.
To review the logs locally, you can also use the AWS SAM CLI to retrieve CloudWatch logs and then display them in your terminal.
sam logs -n DebuggingExample --region eu-west-1
As a final alternative, you can also execute the Lambda function by choosing Test on the Lambda console. The execution results are displayed in the Log output section.
In the X-Ray console, the Service Map page shows a map of the Lambda function’s connections.
Your Lambda function is essentially standalone. However, the Service Map page can be critical in helping to understand performance issues when a Lambda function is connected with a number of other services.
If you open the Traces screen, the trace list showing all the trace results that it’s recorded. Open one of the traces to see a breakdown of the Lambda function performance.
Conclusion
In this post, I showed you how to develop Lambda functions in .NET Core, how unit tests can be used, how to use the AWS SAM CLI for local integration tests, how CloudWatch can be used for logging and monitoring events, and finally how to use X-Ray to trace Lambda function execution.
Put together, these techniques provide a solid foundation to help you debug and diagnose your Lambda functions effectively. Explore each of the services further, because when it comes to production workloads, great diagnosis is key to providing a great and uninterrupted customer experience.
相關推薦
Developing .NET Core AWS Lambda functions
This post is courtesy of Mark Easton, Senior Solutions Architect – AWS One of the biggest benefits of Lambda functions is that they isolat
AWS Lambda Functions Made Easy
AWS Lambda Functions Made EasyA Step by Step Guide with Code Snippets for Packing Your Python 2.7 Function for AWS LambdaBackgroundI hope the code in this
Invoking AWS Lambda functions via Amazon SNS
We released a new feature today for Amazon SNS that enables developers to perform custom message handling or publish messages to other AWS servic
.NET Core AWS S3雲端儲存
前言 最近有需要用到AWS S3雲端儲存上傳附件,這裡對利用.NET或.NET Core在呼叫SDK APi需要注意的一點小問題做個記錄,或許能對後續有用到的童鞋提供一點幫助 AWS S3雲端儲存 官方已提供針對.NET/.NET Core針對S3的APi(https://docs.aws.amazon.co
AWS Lambda .NET Core 2.0 Support Released
Today we’ve released the highly anticipated .NET Core 2.0 AWS Lambda runtime that is available in all Lambda-supported regions. With .NET Core 2.0
[.net core自我修煉2]SQL、LINQ和Lambda表示式
隨便說說 自己想到什麼就記錄下來了,都是自己遇到的技術點,湊合看吧。在寫後端的時候,最常用的是Lambda表示式,這就記錄一下SQL、LINQ和Lambda的不同之處。 參考資料:https://blog.csdn.net/u010926964/article/details/46240
AWS Lambda enables functions that can run up to 15 minutes
Amazon Web Services is Hiring. Amazon Web Services (AWS) is a dynamic, growing business unit within Amazon.com. We are currently hiring So
.NET Core Global Tools for AWS
One of the exciting new features in .NET Core 2.1 are Global Tools. Global Tools provide the ability to distribute command line tools via a NuGet
AWS伺服器免費套餐部署NET CORE網站
之前的linode充了5美元,一個月就用完了,還是建立的最便宜的伺服器的!!! 以前一直想用用aws的所謂的免費套餐伺服器的,現在linode過期了,可以試著用用了 下面是我的操作流程,包含錯誤及解決方法: 登入aws.amazon.com,註冊個賬號,註冊後登入,彈出介面需要輸入信用卡來驗證,(用於
Invoke AWS Lambda when a State (Execution Event) Changes in AWS Step Functions
Before you begin this procedure, you must: Confirm that the event change that you want to trigger the Lambda function i
AWS Snowball Edge – More Storage, Local Endpoints, Lambda Functions
A I was preparing to write this blog post I went back and read the post I wrote when we launched AWS Snowball last year (AWS Import/Export Snowbal
New AWS X-Ray .NET Core Support
In our AWS re:Invent talk this year, we preannounced support for .NET Core 2.0 with AWS Lambda and support for .NET Core 2.0 with AWS X-Ray. Last
Testing Lambda functions using the AWS Toolkit for Eclipse
In this blog post, I will introduce how to test AWS Lambda functions in Eclipse by using the AWS Toolkit for Eclipse. The AWS Toolkit for Eclipse
.NET Core 2.1 and AWS
We’re excited about the recently released .NET Core 2.1, and we’re sure many of our AWS .NET developers are also eager to get started with .NET Co
ASP.NET Core實現強類型Configuration讀取配置數據
控制器 項目 最好 前言實現讀取JSON文件幾種方式,在項目中采取老辦法簡單粗暴,結果老大過來一看,恩,這樣不太可取,行吧那我就用.NET Core中最新的方式諾,切記,適合的才是最好的,切勿懶。.NET Core讀取JSON文件通過讀取文件方式 當我將VS2015項目用VS2017打開後
ASP .NET core 入門基礎內容備份
表達式model 裏邊設置主鍵 : [key]可以自定義主鍵 默認是名稱為ID類型為int的字段設置顯示格式: [DisplayFormat(DataFormatString="{0:顯示的格式}",[可選參數])設置字段顯示內容 [Display(Name = "要顯示的內容") ] 例: [Displ
從零開始構建一個的asp.net Core 項目(二)
mage .... cfi web execute 運行 figure 今天 deb 接著上一篇博客繼續進行。上一篇博客只是顯示了簡單的MVC視圖頁,這篇博客接著進行,連接上數據庫,進行簡單的CRUD。 首先我在Controllers文件夾點擊右鍵,添加->控制器 彈
在ASP.NET Core MVC中構建簡單 Web Api
程序 Getting Started在 ASP.NET Core MVC 框架中,ASP.NET 團隊為我們提供了一整套的用於構建一個 Web 中的各種部分所需的套件,那麽有些時候我們只需要做一個簡單的 Web Api 程序怎麽辦呢?在 GitHub 中的 ASP.NET Core MVC 源碼裏面,我
十二個 ASP.NET Core 例子——過濾器
implement none ssa 通過 定制化 到你 about sage err 目錄: 過濾器介紹 過濾器類別 自定義過濾器和過濾特性 直接短路返回內容 過濾器與中間件的區別 如果要全局日誌,不要用過濾器 官方文檔傳送門 1.過濾器介紹
.NET Core 部署到CentOS–3.supervisord守護進
dir borde title nbsp otto err 通過 退出 int 1. 安裝 sudo yum install python-setuptoolssudo easy_install supervisor 2. 配置 安裝成功後,輸入supervisord 會顯