{"id":3269,"date":"2015-08-13T20:15:00","date_gmt":"2015-08-13T19:15:00","guid":{"rendered":"https:\/\/www.devco.net\/?p=3269"},"modified":"2015-08-14T12:34:33","modified_gmt":"2015-08-14T11:34:33","slug":"translating-webhooks-with-aws-api-gateway-and-lambda","status":"publish","type":"post","link":"https:\/\/www.devco.net\/archives\/2015\/08\/13\/translating-webhooks-with-aws-api-gateway-and-lambda.php","title":{"rendered":"Translating Webhooks with AWS API Gateway and Lambda"},"content":{"rendered":"<p>Webhooks are great, so many services now support them but I found actually doing anything with them a pain as there are no standards for what goes in them and any 3rd party service you wish to integrate with has to support the particular hooks you are producing.<\/p>\n<p>For instance I want to use SignalFX for my metrics and events but they have very few integrations.  A translator could take an incoming hook and turn it into a SignalFX event and pass it onward.<\/p>\n<p>For a long time I&#8217;ve wanted to build a translator but never got around to doing it because I did not feel like self hosting it and write a whole bunch of supporting infrastructure.  With the release of AWS API Gateway this has become quite easy and really convenient as there are no infrastructure or instances to manage.<\/p>\n<p>I&#8217;ll show a bit of a walk through on how I built a translator that sends events to Signal FX.  Note I do not do any kind of queueing or retrying on the gateway at present so it&#8217;s lossy and best efforts.<\/p>\n<p>AWS Lambda runs stateless functions on demand.  At launch it only supported ingesting their own Events but the recently launched API Gateway lets you front it using a REST API of your own design and this made it a lot easier.<\/p>\n<p>For the rest of this post I assume you&#8217;re over the basic hurdles of signing up for AWS and are already familiar with the basics, so some stuff will be skipped but it&#8217;s not really that complex to get going.<\/p>\n<p><H2>The Code<\/H2><br \/>\nTo get going you need some JS code to handle the translation, here&#8217;s a naive method to convert a GitHub push notification into a SignalFX event:<\/p>\n<p><script src=\"https:\/\/gist.github.com\/ripienaar\/56a537a4848a2a9d99b2.js\"><\/script><\/p>\n<p>This will be the meat of the of the processing and it includes a bit of code to create a request using the https module which includes the SignalFX authentication header.<\/p>\n<p>Note this creates dimensions to the event that is being sent, I guess you can think of them like some kind of key=val tags for the event.  In the Signal FX UI I can select events like this:<\/p>\n<p><center><img decoding=\"async\" src=\"https:\/\/devco.net\/images\/signalfx_event_selection.png\"><\/center><\/p>\n<p>And any other added dimension can be used too, events shows up as little diamonds on graphs, so if I am graphing a service using these dimensions I can pick out events that relate to the branches and repositories that influence the data.<\/p>\n<p>This is called as below:<\/p>\n<p><script src=\"https:\/\/gist.github.com\/ripienaar\/73863a0805df0cb2ab93.js\"><\/script><\/p>\n<p>There&#8217;s some stuff not shown here for brevity, it&#8217;s all in <a href=\"https:\/\/github.com\/ripienaar\/lambda_webhook_gwy\">GitHub<\/a>. The entry point here is <em>handleGitHubPushNotifications<\/em>, this is the Lambda function that will be run.  I can put many different ones in here and in the previous code and share this same zip file across many functions.  All I have to do is tell Lambda to run <em>handleGitHubPushNotifications<\/em> or <em>handleOpsGeniePushNotifications<\/em> etc. so this is a library of functions. See the next section for how.<\/p>\n<p><H2>Setting up the Lambda functions<\/H2><\/p>\n<p>We have to create a Lambda function, for now I&#8217;ll use the console but you can use terraform for this it helps quite a lot.  <\/p>\n<p>As this repo is made up of a few files your only option is to zip it up.  You&#8217;ll have to clone it and make your own <em>config.js<\/em> based on the sample prior to creating the zip file.  <\/p>\n<p>Once you have it just create a Lambda function which I&#8217;ll call <em>gitHubToSFX<\/em> and choose your zip file as source.  While setting it up you have to supply a <em>handler<\/em>.  This is how Lambda finds your function to call.<\/p>\n<p>In my case I specify <em>index.handleGitHubPushNotifications<\/em> &#8211; uses the <em>handleGitHubPushNotifications<\/em> function found in <em>index.js<\/em>.<\/p>\n<p>It ends up looking like this:<\/p>\n<p><center><img decoding=\"async\" src=\"https:\/\/devco.net\/images\/lambda_create_gitHubToSFX.png\"><\/center><\/p>\n<p>Once created you can test it right there if you have a sample GitHub commit message.<\/p>\n<p><H2>The REST End Point<\/H2><\/p>\n<p>Now we need to create somewhere for GitHub to send the POST request to. Gateway works with resources and methods.  A resource is something like <em>\/github-hook<\/em> and a method is <em>POST<\/em>.<\/p>\n<p>I&#8217;ve created the resource and method, and told it to call the Lambda function here:<\/p>\n<p><center><img decoding=\"async\" src=\"https:\/\/devco.net\/images\/api_gateway_create_github-hook.png\"><\/center><\/p>\n<p>You have to deploy your API &#8211; just hit the big <em>Deploy API<\/em> button and follow the steps, you can create stages like development, staging, production and deploy API&#8217;s through such a life cycle.  I just went straight to prod.<\/p>\n<p>Once deployed it gives you a URL like <em>https:\/\/12344xnb.execute-api.eu-west-1.amazonaws.com\/prod<\/em> and your GitHub hook would be configured to hit <em>https:\/\/12344xnb.execute-api.eu-west-1.amazonaws.com\/prod\/github-hook<\/em> .<\/p>\n<p><H2>Conclusion<\/H2><br \/>\nThat&#8217;s about it, once you&#8217;ve configured GitHub you&#8217;ll start seeing events flow through.  <\/p>\n<p>Both Lambda and API Gateway can write logs to Cloud Watch and from the JS side you can see do something like <em>console.log(&#8220;hello&#8221;)<\/em> and this will show up in the Cloud Watch logs to help with debugging.<\/p>\n<p>I hope to start gathering a lot of translations like these and am still learning Node, so not really sure yet how to make packages or classes but so far this seems really easy to use.<\/p>\n<p>Cost wise it&#8217;s really cheap.  You&#8217;d pay $3.50 per million API calls received on the Gateway and $0.09\/GB for the transfer costs, but given the nature of these events this will be negligible. Lambda is free for the first 1 million requests and you&#8217;ll pay some tiny amount for the time used.  They are both eligible for the free tier too in case you&#8217;re new to AWS.<\/p>\n<p>There are many advantages to this approach:<\/p>\n<ul>\n<li>It&#8217;s very cheap as there are no instances to run, just the requests<\/li>\n<li>Adding webhooks to many services is a clickfest hell. This gives me a API that I can change the underlying logic of without updating GitHub etc<\/li>\n<li>Today I use SignalFX but it&#8217;s event feature is pretty limited, I can move all the events elsewhere on the backend without any API changes<\/li>\n<li>I can use my own domain and SSL certs<\/li>\n<li>As the REST API is pretty trivial I can later move it in-house if I need, again without changing any 3rd parties &#8211; assuming I set up my own domain<\/li>\n<\/ul>\n<p>I have 2 outstanding issues to address:<\/p>\n<ul>\n<li>How to secure it, API Gateway supports headers as tokens but this is not something webhooks tend to support<\/li>\n<li>Monitoring it, I do not want to some webhook sender to get in a loop and send 100s of thousands of requests without it going unnoticed<\/li>\n<\/ul>\n","protected":false},"excerpt":{"rendered":"<p>Webhooks are great, so many services now support them but I found actually doing anything with them a pain as there are no standards for what goes in them and any 3rd party service you wish to integrate with has to support the particular hooks you are producing. For instance I want to use SignalFX [&hellip;]<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_et_pb_use_builder":"","_et_pb_old_content":"","footnotes":""},"categories":[7],"tags":[120,119,121,85],"_links":{"self":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts\/3269"}],"collection":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/comments?post=3269"}],"version-history":[{"count":14,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts\/3269\/revisions"}],"predecessor-version":[{"id":3283,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/posts\/3269\/revisions\/3283"}],"wp:attachment":[{"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/media?parent=3269"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/categories?post=3269"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.devco.net\/wp-json\/wp\/v2\/tags?post=3269"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}