pastebin

Paste Search Dynamic
Recent pastes
data store read
  1. def data_store_read(data_set):
  2.     """
  3.    This function reads data from datastore
  4.  
  5.    Args:
  6.        data_set:
  7.            ------------------------------------------------------------------------------
  8.                table name       | input parameter    | xyz
  9.                where            | input parameter    | $col1 = 'Hello' AND name = 'Mini'
  10.                columns          | optional parameter | name, age
  11.                data store: read | common action      | variable_name_to_save_data_to
  12.            ------------------------------------------------------------------------------
  13.    Return:
  14.        `list of datastore` if success
  15.        `zeuz_failed` if fails
  16.    """
  17.  
  18.     sModuleInfo = inspect.currentframe().f_code.co_name + " : " + MODULE_NAME
  19.  
  20.     try:
  21.         table_name = columns = var_name = ""
  22.         params = {}
  23.         for left, mid, right in data_set:
  24.             if left.strip() == 'table name':
  25.                 table_name = right.strip()
  26.                 params['table_name'] = table_name
  27.             if left.strip() == 'where':
  28.                 q = right.strip()
  29.                 temp = q.lower().replace('and', ',').replace('or', ',').split(',')
  30.  
  31.                 t = temp[0].split('=')
  32.                 params['and_' + t[0].strip()] = t[1].strip()
  33.                 i = 1
  34.                 for s in q.split():
  35.                     if s.lower() == 'and':
  36.                         t = temp[i].split('=')
  37.                         params['and_' + t[0].strip()] = t[1].strip()
  38.                         i+=1
  39.  
  40.                     if s.lower() == 'or':
  41.                         t = temp[i].split('=')
  42.                         params['or_'+t[0].strip()] = t[1].strip()
  43.  
  44.                         i += 1
  45.  
  46.         headers = RequestFormatter.add_api_key_to_headers({})
  47.         headers['headers']['content-type']='application/json'
  48.         headers['headers']['X-API-KEY']='4ffcc915-70ab-4ffa-89bb-d68ac1c91101'
  49.         res = requests.get(
  50.             RequestFormatter.form_uri('data_store/data_store/custom_operation/'),
  51.             params=json.dumps(params),
  52.             verify=false,
  53.             **headers
  54.         )
  55.         #
  56.  
  57.         # print(res.text)
  58.         CommonUtil.ExecLog(sModuleInfo, f"Captured following output:n{res.text}", 1)
  59.  
  60.         return sr.Set_Shared_Variables(var_name, json.loads(res.text))
  61.  
  62.     except exception:
  63.         return CommonUtil.Exception_Handler(sys.exc_info())
  64.  
  65. def data_store_write(data_set):
  66.     """
  67.    This function reads data from datastore
  68.  
  69.    Args:
  70.        data_set:
  71.            ------------------------------------------------------------------------------
  72.                table name       | input parameter    | xyz
  73.                where            | input parameter    | $col1 = 'Hello' AND name = 'Mini'
  74.                columns          | optional parameter | name, age
  75.                data             | element parameter | column_name=Arifa
  76.                data store: read | common action      | variable_name_to_save_data_to
  77.            ------------------------------------------------------------------------------
  78.    Return:
  79.        `list of datastore` if success
  80.        `zeuz_failed` if fails
  81.    """
  82.  
  83.     sModuleInfo = inspect.currentframe().f_code.co_name + " : " + MODULE_NAME
  84.  
  85.     try:
  86.         table_name = columns = var_name = ""
  87.         params = {}
  88.         data={}
  89.         for left, mid, right in data_set:
  90.             if left.strip() == 'table name':
  91.                 table_name = right.strip()
  92.                 params['table_name'] = table_name
  93.             if left.strip() == 'where':
  94.                 q = right.strip()
  95.                 temp = q.lower().replace('and', ',').replace('or', ',').split(',')
  96.  
  97.                 t = temp[0].split('=')
  98.                 params['and_' + t[0].strip()] = t[1].strip()
  99.                 i = 1
  100.                 for s in q.split():
  101.                     if s.lower() == 'and':
  102.                         t = temp[i].split('=')
  103.                         params['and_' + t[0].strip()] = t[1].strip()
  104.                         i+=1
  105.  
  106.                     if s.lower() == 'or':
  107.                         t = temp[i].split('=')
  108.                         params['or_'+t[0].strip()] = t[1].strip()
  109.  
  110.                         i += 1
  111.             if left.strip() == 'data':
  112.                 temp = right.strip().split(',')
  113.                 for t in temp:
  114.                     tt=t.split('=')
  115.                     data[tt[0].strip()]=tt[1].strip()
  116.         headers = RequestFormatter.add_api_key_to_headers({})
  117.         headers['headers']['content-type']='application/json'
  118.         headers['headers']['X-API-KEY']='4ffcc915-70ab-4ffa-89bb-d68ac1c91101'
  119.         res = requests.patch(
  120.             RequestFormatter.form_uri('data_store/data_store/custom_operation/'),
  121.             params=json.dumps(params),
  122.             data=json.dumps(data),
  123.             verify=false,
  124.             **headers
  125.         )
  126.         #
  127.  
  128.         # print(res.text)
  129.         CommonUtil.ExecLog(sModuleInfo, f"Captured following output:n{res.text}", 1)
  130.  
  131.         return sr.Set_Shared_Variables(var_name, json.loads(res.text))
  132.  
  133.     except exception:
  134.         return CommonUtil.Exception_Handler(sys.exc_info())
Parsed in 0.053 seconds