14
14
15
15
package org .demo .batch .sqs ;
16
16
17
- import com .amazonaws .services .lambda .runtime .Context ;
18
- import com .fasterxml .jackson .databind .ObjectMapper ;
19
17
import java .io .File ;
20
18
import java .io .IOException ;
21
19
import java .util .Arrays ;
22
20
import java .util .Random ;
21
+
23
22
import org .demo .batch .model .Product ;
24
23
import org .slf4j .Logger ;
25
24
import org .slf4j .LoggerFactory ;
26
25
import org .slf4j .MDC ;
26
+
27
+ import com .fasterxml .jackson .databind .ObjectMapper ;
28
+
27
29
import software .amazon .awssdk .core .sync .RequestBody ;
28
30
import software .amazon .awssdk .http .urlconnection .UrlConnectionHttpClient ;
29
31
import software .amazon .awssdk .services .s3 .S3Client ;
30
32
import software .amazon .awssdk .services .s3 .model .PutObjectRequest ;
31
- import software .amazon .lambda .powertools .logging .Logging ;
32
33
import software .amazon .lambda .powertools .tracing .Tracing ;
33
34
import software .amazon .lambda .powertools .tracing .TracingUtils ;
34
35
@@ -43,23 +44,23 @@ public class AbstractSqsBatchHandler {
43
44
* Simulate some processing (I/O + S3 put request)
44
45
* @param p deserialized product
45
46
*/
46
- @ Logging
47
47
@ Tracing
48
48
protected void processMessage (Product p ) {
49
49
TracingUtils .putAnnotation ("productId" , p .getId ());
50
50
TracingUtils .putAnnotation ("Thread" , Thread .currentThread ().getName ());
51
51
MDC .put ("product" , String .valueOf (p .getId ()));
52
52
LOGGER .info ("Processing product {}" , p );
53
53
54
- char c = (char )(r .nextInt (26 ) + 'a' );
54
+ char c = (char ) (r .nextInt (26 ) + 'a' );
55
55
char [] chars = new char [1024 * 1000 ];
56
56
Arrays .fill (chars , c );
57
57
p .setName (new String (chars ));
58
58
try {
59
- File file = new File ("/tmp/" + p .getId ()+ ".json" );
59
+ File file = new File ("/tmp/" + p .getId () + ".json" );
60
60
mapper .writeValue (file , p );
61
61
s3 .putObject (
62
- PutObjectRequest .builder ().bucket (bucket ).key (p .getId ()+".json" ).build (), RequestBody .fromFile (file ));
62
+ PutObjectRequest .builder ().bucket (bucket ).key (p .getId () + ".json" ).build (),
63
+ RequestBody .fromFile (file ));
63
64
} catch (IOException e ) {
64
65
throw new RuntimeException (e );
65
66
} finally {
0 commit comments