function decodeParkingReadings( triggerInput ) { parsePubSubMessage(triggerInput) .then(decode) .then(converToCommand) .then(PubSub.topic(‘DeviceCommands’).publish) }
1 - (Order Created) orderNumber: 123foo items: [ item: redShirt, size: XL, quantity: 2 ] shippingAddress: 123 Bar Lane 2 - (Address Changed) orderNumber: 123foo shippingAddress: 456 Infinite Loop 3 - (Quantity Changed) orderNumber: 123foo items: [ item: redShirt, size: XL, quantity: 1 ]
exports.exportStuffToBigQuery = function exportStuffToBigQuery( event, callback ) { return parseEvent(event) .then(( eventData ) => { const BigQuery = require('@google-cloud/bigquery')(); return BigQuery.dataset('myData').table('stuff').insert(eventData); }) .then(( ) => callback()) };
exports.exportStuffToBigQuery = function exportStuffToBigQuery( event, callback ) { myFunction.run(event, callback, (( data ) => { myFunction.sendOutput(eventData) }); };
1) Parse trigger 2) Do stuff 3) Send output 4) Issue callback 5) Catch errors
1) Filter unneeded events 2) Log start 3) Parse trigger 4) Do stuff 5) Send output(s) 6) Issue retry for timeout errors 7) Catch and log all fatal errors (no retry) 8) Issue callback 9) Do it all asynchronously 10) Test above code 11) Create environment resources (if needed) 12) Deploy code
const options = { functionName: 'doStuff', trigger: 'stuff-commands', triggerType: 'pubsub', aggregateType: 'devices', aggregateSource: 'bigtable', targets: [ { type: 'bigtable', name: 'stuff' }, { type: 'pubsub', name: 'stuff-events'} ], filter: [ 'UpdateStuff' ] };
{ fact: { id: "19fg-3fsf-gg49", type: "Command", subtype: "UpdateReadings" }, readings: {} }
Demonstrate your proficiency to design, build and manage solutions on Google Cloud Platform.
Follow