企业应用上云的新花样：利用 Amazon API Gateway 和 AWS Lambda 实现 SAP 应用微服务化

   {       "agencynum":"00133333",       "NAME":"ACME Holiday",       "STREET":"Jiuxianqiao Road",       "POSTCODE":"100000",       "CITY":"Beijing",       "COUNTRY":"CN",       "TELEPHONE":"010-88888888",       "URL":"http://www.acmeholiday.aws",       "LANGU":"CN",       "CURRENCY":"CNY",       "mimeType":"text/html"   }

[](https://s3.cn-north-1.amazonaws.com.cn/awschinablog/amazon-lambda-sap(11).png)](https://s3.cn-north-1.amazonaws.com.cn/awschinablog/amazon-lambda-sap(11).png)

   {       "Version": "2012-10-17",       "Statement": [           {               "Effect": "Allow",               "Action": [                   "logs:CreateLogGroup",                   "logs:CreateLogStream",                   "logs:PutLogEvents"               ],               "Resource": "arn:aws-cn:logs:*:*:*"           },           {               "Effect": "Allow",               "Action": [                   "ec2:CreateNetworkInterface",                   "ec2:DescribeNetworkInterfaces",                   "ec2:DetachNetworkInterface",                   "ec2:DeleteNetworkInterface"               ],               "Resource": "*"           }       ]   }

   exports.handler = (event, context, callback) => {
       const done = (err, res) => callback(null, {           statusCode: err ? '400' : '200',           body: err ? err.message : res,           headers: {               'Content-Type': 'application/json',           },       });
       var endpoint = {               host: event.requestParams.hostname,               port: event.requestParams.port,               path: event.requestParams.path,               username: event.requestParams.username,               password: event.requestParams.password       };
       switch (event.requestParams.httpMethod) {           case 'GET':               getTravelAgency(endpoint, event.requestParams.agencynum, done);               break;           case 'POST':               postTravelAgency(endpoint, event.requestParams.body, done);               break;           default:               done(new Error(`Unsupported methods "${event.requestParams.httpMethod}"`));       }   };

   //return travel agency information based on parameters   //'use strict';   var http = require('http');
   exports.getTravelAgency = (ep, params, callback) => {
       if (params == "" ) callback(new Error("Parameter 'carrierid' has not been provided"));
       var sAuth = 'Basic ';       sAuth += new Buffer(ep.username + ':' + ep.password).toString('base64');
       var headers = {         'Authorization': sAuth       };
       var options = {           host : ep.host,           port : ep.port,           path : ep.path + "(\'"+ params+ "\')?$format=json",           method : "GET",           headers : headers       };
       var req=http.request(options,function(res){           res.setEncoding("utf-8");           var responseString = '';           res.on('data',function(chunk){               responseString += chunk;           });           res.on('end', function () {           callback(undefined, JSON.parse(responseString));         });       });
       req.end();
       req.on("error",function(err){           callback(new Error(err.message));       });   }

   //add new travel agency based on parameters   //'use strict';   var http = require('http');   var xml2js = require('xml2js');   //var sapapi = require('./sapapi');   //var extsys = require('./settings').extsys;
   exports.postTravelAgency = (ep, data, callback) => {
       //callback(new Error(JSON.stringify(data)));
       if (data == "" ) callback(new Error("Parameter 'data' has not been provided"));
       var sAuth = 'Basic ';       sAuth += new Buffer(ep.username + ':' + ep.password).toString('base64');
       var oGetRequest = new Promise(function (resolve, reject) {           // body...           var headers = {             'Authorization': sAuth,             'x-csrf-token': "fetch"           };
           var options = {               host : ep.host,               port : ep.port,               path : ep.path,               method : "GET",               headers : headers           };
           //request x-csrf-token           var req=http.request(options,function(res){               resolve(res);                   });
           req.setTimeout(60000, function () {         reject( new Error("Server is unreachable"));       });       req.end();       req.on('error', function (error) {          reject(error);       });       });
       oGetRequest.then(           //resolve           function (oGetRes) {               //payload from request               var dataString = JSON.stringify(data);
               var headers = {};               headers['Authorization'] = sAuth;               headers['Accept-Language'] = 'en';               headers['X-Requested-With'] = "XMLHttpRequest";               headers['Content-Type'] = 'application/json';               headers['X-CSRF-Token'] = oGetRes.headers['x-csrf-token'];               headers['cookie'] = oGetRes.headers['set-cookie'];
               var options = {                   host : ep.host,                   port : ep.port,                   path : ep.path,                   method : "POST",                   headers : headers               };
         var req = http.request(options, function (res) {
           if (res.statusCode !== 201) return callback(new Error(res.statusCode));
           res.setEncoding('utf-8');
           var responseString = '';
           res.on('data', function (data) {             responseString += data;             //callback(new Error(responseString));           });
           res.on('end', function () {               var parser = new xml2js.Parser();               //callback(undefined, parser.parseString(responseString));               callback(undefined, responseString);           });         });            
         req.write(dataString);         req.end();         req.on('error', function (error) {           callback(new Error(error.message));         });                       },
       // reject       function (err) {         callback(new Error(err.message));       }               );   }

<pre>
</pre>