node.js - AWS Personalize 发送事件

Question

我在 AWS 个性化文档上，它说在此处访问 node.js 代码。

More code examples (in Node.js, Python, and Go) and AWS Lambda usage guidelines are found here.

这是哪里？？？我正在尝试在不使用 lambda 的情况下使用 nodejs。如何在没有 lambda 的情况下从我的节点服务器发送等价物，甚至可能吗？

这是Java代码。

package example;

  public class ProcessKinesisRecords implements RequestHandler<KinesisEvent, Void>{
  
      private static final String TRACKING_ID = be5aa88c-05dd-4c5e-9372-15ffa6a846b9;
      private EndpointConfiguration endpointConfiguration = new EndpointConfiguration("http://concierge-gamma-events.us-west-2.amazonaws.com", "us-west-2");
      private AWSConciergeEventTracking client = AWSConciergeEventTrackingClientBuilder.standard()
                  .withEndpointConfiguration(endpointConfiguration).build();
      private final CharsetDecoder decoder = Charset.forName("UTF-8").newDecoder();
  
      @Override
      public Void recordHandler(KinesisEvent event, Context context)
      {
          for(KinesisEventRecord rec : event.getRecords()) {
              try {
                  // Kinesis data is Base64 encoded and needs to be decoded before being used.
                  String data = decoder.decode(record.getKinesis().getData()).toString();
  
                  JSONParser parser = new JSONParser();
                  JSONObject jsonObject = (JSONObject) parser.parse(data);
                  String userId = (String) jsonObject.get(USER_ID);
                  String sessionId = (String) jsonObject.get(SESSION_ID);
                  String eventType = (String) jsonObject.get(EVENT_TYPE);
                  long timestamp= new Date().getTime();
                  ByteBuffer properties = jsonObject.get(EVENT_TYPE).getBytes("UTF-8");
  
                  List<Event> eventList = new ArrayList<>();
                  eventList.add(new Event().withProperties(properties).withType(eventType));
                  TrackRequest request = new TrackRequest()
                          .withTrackingId(EVENT_TRACKER_ARN)
                          .withChannel("server")
                          .withUserId(userId)
                          .withSessionId(sessionId)
                          .withEventList(eventList);
                  client.track(request);
              } catch (CharacterCodingException e) {
                  log.error("Error decoding data in the kinesis stream. ", e);
                  throw new IllegalArgumentException(e.getMessage());
              } catch (ParseException e) {
                  log.error("Error parsing JSON input from the kinesis stream. ", e);
                  throw new IllegalArgumentException(e.getMessage());
              } catch (Exception e) {
                  log.error("Error processing record. ", e);
                  throw new IllegalArgumentException(e.getMessage());
              }
          return null;
      }
  }

Answer 1

实际上，所有这些都在 AWS SDK for Node 环境中提供。经过一番研究，我想出了以下代码。

这只是一个草稿，并表明它有效。

let AWS = require ('aws-sdk');

AWS.config.update({
    'region': 'eu-central-1', // process.env.REGION,
    'accessKeyId': 'XXXX', // process.env.AWS_ACCESS_KEY_ID,
    'secretAccessKey': 'XXXXXXX' // process.env.AWS_SECRET_ACCESS_KEY
});

let personalizeEvents = new AWS.PersonalizeEvents();

var params = {
    eventList: [ /* required */
        {
            eventType: 'click', /* required */
            sentAt: new Date || 'Wed Dec 31 1969 16:00:00 GMT-0800 (PST)' || 123456789, /* required */
            eventId: 'STRING_VALUE',
            eventValue: 11,
            impression: [
                'STRING_VALUE',
                /* more items */
            ],
            itemId: '1',
            //properties: any /* This value will be JSON encoded on your behalf with JSON.stringify() */,
            recommendationId: 'STRING_VALUE'
        },
    ],
    sessionId: 'STRING_VALUE', /* required */
    trackingId: 'trackerid', /* required */
    userId: '666'
};

personalizeEvents.putEvents(params, function (err, data) {
    if (err) console.log(err, err.stack); // an error occurred
    else     console.log(data);           // successful response
});

请先阅读这篇，AWS官方文档了解。

然后查看API 文档。