feat(filterPattern): Adding option for overriding default filter pattern

README.md

@@ -52,6 +52,19 @@ custom:
     endpoint: some-elasticsearch-endpoint.us-east-1.es.amazonaws.com
 ```
 
+#### filterPattern
+
+(Optional) The filter pattern that the Cloudwatch subscription should use for your lambda
+functions. Default is `[timestamp=*Z, request_id="*-*", event]`. See
+[Cloudwatch filter pattern syntax](https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/FilterAndPatternSyntax.html)
+for more info.
+
+```yaml
+custom:
+  esLogs:
+    filterPattern: '[timestamp=*Z, request_id="*-*", event]'
+```
+
 #### includeApiGWLogs
 
 (Optional) An option to be used in conjunction with the [serverless-aws-alias](https://github.com/HyperBrain/serverless-aws-alias) plugin. This will capture logs created by API Gateway and transport them to Elasticsearch.

src/index.ts

@@ -16,6 +16,8 @@ class ServerlessEsLogsPlugin {
   private custom: { [name: string]: any };
   private logProcesserDir: string = '_es-logs';
   private logProcesserName: string = 'esLogsProcesser';
+  private defaultLambdaFilterPattern: string = '[timestamp=*Z, request_id="*-*", event]';
+  private defaultApiGWFilterPattern: string = '[apigw_request_id="*-*", event]';
 
   constructor(serverless: any, options: { [name: string]: any }) {
     this.serverless = serverless;
@@ -111,7 +113,7 @@ class ServerlessEsLogsPlugin {
   }
 
   private addApiGwCloudwatchSubscription(): void {
-    const filterPattern = '[apigw_request_id="*-*", event]';
+    const filterPattern = this.defaultApiGWFilterPattern;
     const apiGatewayStageLogicalId = 'ApiGatewayStage';
     const processorAliasLogicalId = 'EsLogsProcesserAlias';
     const template = this.serverless.service.provider.compiledCloudFormationAliasTemplate;
@@ -178,7 +180,8 @@ class ServerlessEsLogsPlugin {
   }
 
   private addLambdaCloudwatchSubscriptions(): void {
-    const filterPattern = '[timestamp=*Z, request_id="*-*", event]';
+    const { esLogs } = this.custom;
+    const filterPattern = esLogs.filterPattern || this.defaultLambdaFilterPattern;
     const template = this.serverless.service.provider.compiledCloudFormationTemplate;
     const functions = this.serverless.service.getAllFunctions();
     const processorLogicalId = 'EsLogsProcesserLambdaFunction';