gihankarunarathne

# You can pass `execution_options` such as https://github.com/googleapis/python-spanner-sqlalchemy#stale-reads.
# You don't need to set them while creating the Spanner db instance.

def foo():
      with engines.get_engine('purchase').execution_options(read_only=True).connect() as conn:
        reseller_thresholds = zsql(
            conn,
            '''
            SELECT
                p.ref_type,

gihankarunarathne

SELECT		
    p.ref_type,		
    p.ref_code,		
    p.sku,		
    rt.id_product_fulltype,		
    rt.sku_category,		
    COALESCE(ANY_VALUE(rt.threshold), rp.default_threshold) AS threshold,		
    SUM(item_status) AS purchased_count		
FROM reseller.purchase_history p
LEFT JOIN reseller.reseller_sku_category rsc ON rsc.sku = p.value_code AND 'sku' = p.value_type

gihankarunarathne

/**
 * Handle Throttling Values and restrict accessing when throttling
 * value exceeded.
 * 
 * This class implementation is inspired from Redis
 * Refer: http://redis.io/commands/incr#pattern-rate-limiter-1
 *
 * Gihan Karunarathne <[email protected]>
 */
'use strict';

gihankarunarathne

#!/usr/bin/env python

from idlelib.PyShell import main

if __name__ == '__main__':
    main()

gihankarunarathne

function() {
  var self = this;
  var url = apiUrl + "/containers/" + containerId + "/stats";
  // var url =  "/docker/containers/" + containerId + "/stats";
  console.log('URL ', url);

  oboe(url)
    .node('*', function(data) {
      console.log('Data ', data);
    })