Commitbb2a15c

committed

Add analytics rules resource.

1 parent765c996 commitbb2a15cCopy full SHA for bb2a15c

File tree

+100

-1

lines changed

+100

-1

lines changed

Lines changed: 58 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,58 @@`
	`1`	`+importtypesense`
	`2`	`+`
	`3`	`+client=typesense.Client({`
	`4`	`+'api_key':'abcd',`
	`5`	`+'nodes': [{`
	`6`	`+'host':'localhost',`
	`7`	`+'port':'8108',`
	`8`	`+'protocol':'http'`
	`9`	`+ }],`
	`10`	`+'connection_timeout_seconds':2`
	`11`	`+})`
	`12`	`+`
	`13`	`+# Drop pre-existing rule if any`
	`14`	`+try:`
	`15`	`+client.analytics_rules['top_queries'].delete()`
	`16`	`+exceptExceptionase:`
	`17`	`+pass`
	`18`	`+`
	`19`	`+# Create a new rule`
	`20`	`+create_response=client.analytics_rules.create({`
	`21`	`+"name":"top_queries",`
	`22`	`+"type":"popular_queries",`
	`23`	`+"params": {`
	`24`	`+"source": {`
	`25`	`+"collections": ["products"]`
	`26`	`+ },`
	`27`	`+"destination": {`
	`28`	`+"collection":"top_queries"`
	`29`	`+ },`
	`30`	`+"limit":1000`
	`31`	`+ }`
	`32`	`+})`
	`33`	`+print(create_response)`
	`34`	`+`
	`35`	`+# Try to fetch it back`
	`36`	`+print(client.analytics_rules['top_queries'].retrieve())`
	`37`	`+`
	`38`	`+# Update the rule`
	`39`	`+update_response=client.analytics_rules.upsert('top_queries', {`
	`40`	`+"name":"top_queries",`
	`41`	`+"type":"popular_queries",`
	`42`	`+"params": {`
	`43`	`+"source": {`
	`44`	`+"collections": ["products"]`
	`45`	`+ },`
	`46`	`+"destination": {`
	`47`	`+"collection":"top_queries"`
	`48`	`+ },`
	`49`	`+"limit":100`
	`50`	`+ }`
	`51`	`+})`
	`52`	`+print(update_response)`
	`53`	`+`
	`54`	`+# List all rules`
	`55`	`+print(client.analytics_rules.retrieve())`
	`56`	`+`
	`57`	`+# Delete the rule`
	`58`	`+print(client.analytics_rules['top_queries'].delete())`

Lines changed: 14 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,14 @@`
	`1`	`+classAnalyticsRule(object):`
	`2`	`+def__init__(self,api_call,rule_id):`
	`3`	`+self.api_call=api_call`
	`4`	`+self.rule_id=rule_id`
	`5`	`+`
	`6`	`+def_endpoint_path(self):`
	`7`	`+from .analytics_rulesimportAnalyticsRules`
	`8`	`+returnu"{0}/{1}".format(AnalyticsRules.RESOURCE_PATH,self.rule_id)`
	`9`	`+`
	`10`	`+defretrieve(self):`
	`11`	`+returnself.api_call.get(self._endpoint_path())`
	`12`	`+`
	`13`	`+defdelete(self):`
	`14`	`+returnself.api_call.delete(self._endpoint_path())`

Lines changed: 26 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,26 @@`
	`1`	`+from .analytics_ruleimportAnalyticsRule`
	`2`	`+`
	`3`	`+`
	`4`	`+classAnalyticsRules(object):`
	`5`	`+RESOURCE_PATH='/analytics/rules'`
	`6`	`+`
	`7`	`+def__init__(self,api_call):`
	`8`	`+self.api_call=api_call`
	`9`	`+self.rules= {}`
	`10`	`+`
	`11`	`+def__getitem__(self,rule_id):`
	`12`	`+ifrule_idnotinself.rules:`
	`13`	`+self.rules[rule_id]=AnalyticsRule(self.api_call,rule_id)`
	`14`	`+`
	`15`	`+returnself.rules[rule_id]`
	`16`	`+`
	`17`	`+defcreate(self,rule,params=None):`
	`18`	`+params=paramsor {}`
	`19`	`+returnself.api_call.post(AnalyticsRules.RESOURCE_PATH,rule,params)`
	`20`	`+`
	`21`	`+defupsert(self,id,rule):`
	`22`	`+returnself.api_call.put(u"{0}/{1}".format(AnalyticsRules.RESOURCE_PATH,id),rule)`
	`23`	`+`
	`24`	`+defretrieve(self):`
	`25`	`+returnself.api_call.get(AnalyticsRules.RESOURCE_PATH)`
	`26`	`+`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@`
`6`	`6`	`from .operationsimportOperations`
`7`	`7`	`from .configurationimportConfiguration`
`8`	`8`	`from .api_callimportApiCall`
`9`		`-`
	`9`	`+from .analytics_rulesimportAnalyticsRules`
`10`	`10`
`11`	`11`	`classClient(object):`
`12`	`12`	`def__init__(self,config_dict):`
`@@ -16,5 +16,6 @@ def __init__(self, config_dict):`
`16`	`16`	`self.multi_search=MultiSearch(self.api_call)`
`17`	`17`	`self.keys=Keys(self.api_call)`
`18`	`18`	`self.aliases=Aliases(self.api_call)`
	`19`	`+self.analytics_rules=AnalyticsRules(self.api_call)`
`19`	`20`	`self.operations=Operations(self.api_call)`
`20`	`21`	`self.debug=Debug(self.api_call)`

Comments

(0)