7979
8080 let message = format ! ( "DD_EXTENSION | {level} | {span_prefix}{}" , visitor. 0 ) ;
8181
82- write ! ( writer, "{{\" level\" :\" {level}\" ,\" message\" :\" " ) ?;
82+ // Setting specifically `status` as opposed to `level` since AWS
83+ // filters out logs by the `level` field. This allows our logs to
84+ // appear in CWL regardless of the log level.
85+ write ! ( writer, "{{\" status\" :\" {level}\" ,\" message\" :\" " ) ?;
8386 write_json_escaped ( & mut writer, & message) ?;
8487 writeln ! ( writer, "\" }}" )
8588 }
@@ -187,7 +190,7 @@ mod tests {
187190 let parsed: serde_json:: Value =
188191 serde_json:: from_str ( output. trim ( ) ) . expect ( "output should be valid JSON" ) ;
189192
190- assert_eq ! ( parsed[ "level " ] , "INFO" ) ;
193+ assert_eq ! ( parsed[ "status " ] , "INFO" ) ;
191194 assert ! (
192195 parsed[ "message" ]
193196 . as_str( )
@@ -204,7 +207,7 @@ mod tests {
204207
205208 let parsed: serde_json:: Value =
206209 serde_json:: from_str ( output. trim ( ) ) . expect ( "output should be valid JSON" ) ;
207- assert_eq ! ( parsed[ "level " ] , "ERROR" ) ;
210+ assert_eq ! ( parsed[ "status " ] , "ERROR" ) ;
208211 assert ! (
209212 parsed[ "message" ]
210213 . as_str( )
@@ -221,7 +224,7 @@ mod tests {
221224
222225 let parsed: serde_json:: Value =
223226 serde_json:: from_str ( output. trim ( ) ) . expect ( "output should be valid JSON" ) ;
224- assert_eq ! ( parsed[ "level " ] , "DEBUG" ) ;
227+ assert_eq ! ( parsed[ "status " ] , "DEBUG" ) ;
225228 assert ! (
226229 parsed[ "message" ]
227230 . as_str( )
0 commit comments