|
5 | 5 | import com.amazonaws.services.lambda.runtime.Context; |
6 | 6 | import com.amazonaws.services.lambda.runtime.LambdaLogger; |
7 | 7 |
|
| 8 | +import java.text.SimpleDateFormat; |
| 9 | +import java.util.Date; |
| 10 | +import java.util.UUID; |
8 | 11 | import java.util.logging.Level; |
9 | 12 | import java.util.logging.Logger; |
10 | 13 |
|
11 | 14 | public class LambdaContext implements Context { |
12 | 15 |
|
13 | | - private final Logger LOG = Logger.getLogger(LambdaContext.class.getName()); |
| 16 | + private static final int DEFAULT_MEMORY_SIZE_IN_MB = 256; |
| 17 | + private static final String DEFAULT_ACCOUNT_ID = "123456789012"; |
| 18 | + private static final String DEFAULT_REGION = "us-east-1"; |
| 19 | + private static final String DEFAULT_FUNCTION_NAME = "localstack"; |
| 20 | + private static final String DEFAULT_FUNCTION_VERSION = "$LATEST"; |
14 | 21 |
|
15 | | - public LambdaLogger getLogger() { |
16 | | - return new LambdaLogger() { |
| 22 | + private static final String TODAY = new SimpleDateFormat("yyyy/MM/dd").format(new Date()); |
| 23 | + private static final String CONTAINER_ID = UUID.randomUUID().toString(); |
17 | 24 |
|
18 | | - @Override |
19 | | - public void log(String msg) { |
20 | | - LOG.log(Level.INFO, msg); |
21 | | - } |
| 25 | + private final Logger LOG = Logger.getLogger(LambdaContext.class.getName()); |
22 | 26 |
|
23 | | - @Override |
24 | | - public void log(byte[] msg) { |
25 | | - log(new String(msg)); |
26 | | - } |
27 | | - }; |
28 | | - } |
| 27 | + private final String requestId; |
29 | 28 |
|
30 | | - public String getAwsRequestId() { |
31 | | - // TODO Auto-generated method stub |
32 | | - return null; |
| 29 | + public LambdaContext(String requestId) { |
| 30 | + this.requestId = requestId; |
33 | 31 | } |
34 | 32 |
|
35 | | - public ClientContext getClientContext() { |
36 | | - // TODO Auto-generated method stub |
37 | | - return null; |
| 33 | + @Override |
| 34 | + public String getAwsRequestId() { |
| 35 | + return requestId; |
38 | 36 | } |
39 | 37 |
|
| 38 | + @Override |
40 | 39 | public String getFunctionName() { |
41 | | - // TODO Auto-generated method stub |
42 | | - return null; |
| 40 | + String functionName = System.getenv("AWS_LAMBDA_FUNCTION_NAME"); |
| 41 | + if (functionName == null) { |
| 42 | + functionName = DEFAULT_FUNCTION_NAME; |
| 43 | + } |
| 44 | + return functionName; |
43 | 45 | } |
44 | 46 |
|
| 47 | + @Override |
45 | 48 | public String getFunctionVersion() { |
46 | | - // TODO Auto-generated method stub |
47 | | - return null; |
48 | | - } |
49 | | - |
50 | | - public CognitoIdentity getIdentity() { |
51 | | - // TODO Auto-generated method stub |
52 | | - return null; |
| 49 | + String functionVersion = System.getenv("AWS_LAMBDA_FUNCTION_VERSION"); |
| 50 | + if (functionVersion == null) { |
| 51 | + functionVersion = DEFAULT_FUNCTION_VERSION; |
| 52 | + } |
| 53 | + return functionVersion; |
53 | 54 | } |
54 | 55 |
|
| 56 | + @Override |
55 | 57 | public String getInvokedFunctionArn() { |
56 | | - // TODO Auto-generated method stub |
57 | | - return null; |
| 58 | + String region = System.getenv("AWS_REGION"); |
| 59 | + if (region == null) { |
| 60 | + region = DEFAULT_REGION; |
| 61 | + } |
| 62 | + return String.format("arn:aws:%s:%s:function:%s:%s", |
| 63 | + region, DEFAULT_ACCOUNT_ID, getFunctionName(), getFunctionVersion()); |
58 | 64 | } |
59 | 65 |
|
| 66 | + @Override |
60 | 67 | public String getLogGroupName() { |
61 | | - // TODO Auto-generated method stub |
62 | | - return null; |
| 68 | + return String.format("/aws/lambda/%s", getFunctionName()); |
63 | 69 | } |
64 | 70 |
|
| 71 | + @Override |
65 | 72 | public String getLogStreamName() { |
66 | | - // TODO Auto-generated method stub |
67 | | - return null; |
| 73 | + return String.format("%s[%s]%s", TODAY, getFunctionVersion(), CONTAINER_ID); |
68 | 74 | } |
69 | 75 |
|
| 76 | + @Override |
70 | 77 | public int getMemoryLimitInMB() { |
71 | | - // TODO Auto-generated method stub |
72 | | - return 0; |
| 78 | + String memorySize = System.getenv("AWS_LAMBDA_FUNCTION_MEMORY_SIZE"); |
| 79 | + if (memorySize == null) { |
| 80 | + return DEFAULT_MEMORY_SIZE_IN_MB; |
| 81 | + } else { |
| 82 | + try { |
| 83 | + return Integer.parseInt(memorySize); |
| 84 | + } catch (NumberFormatException e) { |
| 85 | + return DEFAULT_MEMORY_SIZE_IN_MB; |
| 86 | + } |
| 87 | + } |
73 | 88 | } |
74 | 89 |
|
| 90 | + @Override |
75 | 91 | public int getRemainingTimeInMillis() { |
76 | | - // TODO Auto-generated method stub |
77 | | - return 0; |
| 92 | + return Integer.MAX_VALUE; |
| 93 | + } |
| 94 | + |
| 95 | + @Override |
| 96 | + public LambdaLogger getLogger() { |
| 97 | + return new LambdaLogger() { |
| 98 | + @Override |
| 99 | + public void log(String msg) { |
| 100 | + LOG.log(Level.INFO, msg); |
| 101 | + } |
| 102 | + |
| 103 | + @Override |
| 104 | + public void log(byte[] msg) { |
| 105 | + log(new String(msg)); |
| 106 | + } |
| 107 | + }; |
| 108 | + } |
| 109 | + |
| 110 | + @Override |
| 111 | + public ClientContext getClientContext() { |
| 112 | + return null; |
| 113 | + } |
| 114 | + |
| 115 | + @Override |
| 116 | + public CognitoIdentity getIdentity() { |
| 117 | + return null; |
78 | 118 | } |
79 | 119 |
|
80 | 120 | } |
0 commit comments