Untitled
unknown
plain_text
2 years ago
4.3 kB
2
Indexable
from models.cache_store import cache_store from models.cache_store_by_username import cache_store_by_username from models.cache_store_by_date import cache_store_by_date from models.indexes import indexes from models.columns import columns as tablecolumns from datetime import datetime, timedelta, timezone from dateutil.relativedelta import relativedelta from pandas.io.json import json_normalize import json from config.logger import configlogfile import base64 from flask import jsonify, make_response import pandas as pd import sys import gc import uuid import pytz from flask import request from flask import Response from json import loads as json_loads from gc import collect as gc_collect from dateutil.parser import parse """ This function is used to fetch cache details based on valueType and key """ def getData(args, configvalues): # UI Based Calling logging = configlogfile() __funcReturnAPICode = '0000' __funcReturnDesc = 'Successfully Completed the Process' businessid=request.args.get('businessid') createdtime=request.args.get('createdtime') username = request.args.get('username') columnMapping = json_loads(configvalues.get('apiconfiguration', 'columnMapping', raw=True)) try: logging.info(("process started")) validArguments = json_loads(configvalues.get('apiconfiguration', 'validArguments', raw=True)) logging.info(("Args.keys() : %s" % set(list(args.keys())))) logging.info(("validArguments : %s" % set(validArguments))) if 'businessid' in args.keys(): results = cache_store.objects.filter(businessid=businessid).allow_filtering() elif 'username' in args.keys(): results = cache_store_by_username.objects.filter(username=username) elif 'createdtime' in args.keys(): try: createdtime = datetime.strptime(createdtime, "%Y-%m-%d %H:%M:%S.%f %z") except ValueError: createdtime=parse(createdtime) results = cache_store_by_date.objects.filter(createdtime=createdtime).allow_filtering() else: return ((["9003"], "Invalid Arguments passed to the API.")) page = request.args.get('page',1) limit = request.args.get('limit',20) if page is not None and limit is not None: try: page=int(page) limit=int(limit) except ValueError: return("400" "both page and limit must be integers") offset = (page - 1) * limit if page is not None and limit is not None else 0 paginated_res=results[offset:offset+limit] data = [{ columnMapping['businessid']: r.businessid, columnMapping['valuetype']: r.valuetype, columnMapping['key']: str(r.key), columnMapping['buid']: r.buid, columnMapping['createdtime']: r.createdtime.isoformat(), columnMapping['opid']: r.opid, columnMapping['updatedtime']: r.updatedtime.isoformat(), columnMapping['username']: r.username, columnMapping['value']: base64.b64encode(r.value).decode('utf-8'), columnMapping['valuetype']: r.valuetype } for r in paginated_res] logging.debug(results) logging.debug(data) response_data={ "data":data } return ("200",(response_data)) the below one is my data in database createdtime | 2023-06-13 11:33:33.772000+0530 key | ConfiguredProductFromSession002527a3-967d-56f0-8d28-bb416c04e67aHOBDEFAULT buid | sdsdsd businessid | 002527a3-967d-46f0-8d28-bb416c04e67a opid | HOB status | null type | java.util.ArrayList updatedtime | 2023-06-13 11:33:33.772000+0530 updatedtimestamp | null username | veera value | 0x7b2244656c6976657279204e6f746573223a20224e6f746573202f22444e2f22227d valuetype | ConfiguredProductFromSession i want to fetch createdtime in the api by like this https://172.16.177.58/HOBSAnalytics/dataservice/cacheStore?createdtime=2023-06-13 11:33:33.772000+0530
Editor is loading...