Service - Sort Result: Difference between revisions

From Izara Wiki
Jump to navigation Jump to search
No edit summary
 
(18 intermediate revisions by the same user not shown)
Line 15: Line 15:
<syntaxhighlight lang="JavaScript">
<syntaxhighlight lang="JavaScript">
{
{
configKey: "ExpiryTimeInSec"
configKey: "SearchType",
configTag: "ExpiryTimeInSec"
configTag: "xx" // {eg: sellOffer/Product/VariantProduct etc..}
configValue: {seconds}
configValue: {
searchResultServiceName: "xx" // {service name of searchResult service that handles this type}
}
},
</syntaxhighlight>
 
== [[Standard WebSocketTask Per Service]] ==
 
== SortResultMain ==
 
<syntaxhighlight lang="JavaScript">
{
sortResultId: "xx", // main element for one set of search results, comes from {searchType}_{filterMainId}
requiredData: {}, // same as request
sortFields: [], // same as request
requestProperties: {}, // same as request
createTime: currentTime.getTime(),
expiryTime: expiryTime.getTime(),
}
}
</syntaxhighlight>
</syntaxhighlight>
: sets the amount of time added to current timestamp to calculated expiry time.
: could extend to have different expiry times depending on, eg the searchType, this could be added to the configTag, empty for default


== SortResults ==
* partition key: sortResultId
* sort key: {none}
* sortResultId: searchId + "_" + sortFieldsHash
* sortFieldsHash: Strip out any sortFields elements after a random element is found, as they are unused. can have multiple sort fields, so we hash them to create the sortFieldsHash unique key


* no sort_key
== SortResultData ==


=== Fields ===
<syntaxhighlight lang="JavaScript">
{
sortResultId: "xx",
sortId: ##, // numeric increment for sorting
dataId: "xx", unique id for the data record, from Search Result service
data: {}, // all required data from Search Result service
}
</syntaxhighlight>


* sortFieldsHash: Strip out any sortFields elements after a random element is found, as they are unused.
* partition key: sortResultId
* sort key: sortId


; sortResultId
== TempStringSort ==
: (partition key)
: comes from searchDataId + "_" + sortFieldsHash
: searchDataId: {searchType}_{filterId}_{keyPropertiesHash}_{requiredDataHash}
: sortFieldsHash: can have multiple sort fields, so we hash them to create the sortFieldsHash unique key
; sortFields
: array (DynamoDB list) of fields being sorted on, or seed value for a random sort
; status
: whether sort processing complete for all data yet
: new_sortresult_created | waiting_for_searchresults | processing | error | complete
; expiry
: timestamp when this data expires and needs to be regenerated


== StringData *probably not using* ==
<syntaxhighlight lang="JavaScript">
{
sortResultIdLevelOrd: "xx",
value: "xx",
}
</syntaxhighlight>


* SortField of data type string is placed into this table, sort is performed using string sorting
* partition key: sortResultIdLevelOrd
* ''level'' splits results into sets, one for each SortFields element, starting at 1 and counting upwards
* sort key: value
* Levels that are not the final level will have one record for each value of the field being searched on
* sortResultIdLevelOrd: is {sortResultId}_{sortLevel}_{previous sort levels order}
* Final level is a special case that has one record for each SearchResultData, we concatenate the unique id onto the sortValue/sort key to create uniqueness, use space as it comes before other characters when sorting strings, might get the odd incorrect sort if lines up with strings that contain actual spaces at the same location, but probably good enough, might be able to find better options like carraige return/tab
* ''data'' is only added if this is the final level of the sortFields array


=== Fields ===
== TempNumericSort ==


; sortDataId
<syntaxhighlight lang="JavaScript">
: (partition key)
{
: comes from {sortResultId}_{level}_{previous level values concatenate with underscore}
sortResultIdLevelOrd: "xx",
; sortValue
value: "xx"
: (sort key)
}
: comes from {value of the field/s being sorted on}, for final level concatenate ~{unique id}
</syntaxhighlight>
; data
: copy of all required data from Search Result service (final level only)
; lowerLevelCount
: number of records in the next level that match this sortValue


== NumericData *probably not using* ==
* partition key: sortResultIdLevelOrd
* sort key: value
* sortResultIdLevelOrd: is {sortResultId}_{sortLevel}_{previous sort levels order}


* SortField of data type numeric is placed into this table, sort is performed using numeric sorting
== TempSortDataId ==
* ''level'' splits results into sets, one for each SortFields element, starting at 1 and counting upwards
* Levels that are not the "f" level will have one record for each value of the field being searched on
* If the final SortField level is numeric an extra level ("f") is created when more than 1 record match the final level's sortValue, in this case the field's unique id as the sortValue/sort key, this is required to achieve uniqueness
* ''data'' is only added if this is the final level of the sortFields array


=== Fields ===
<syntaxhighlight lang="JavaScript">
 
{
; sortDataId
sortResultIdLevelOrdValue: "xx",
: (partition key)
dataId: "xx"
: comes from {sortResultId}_{level}_{previous level values concatenate with underscore}
}
; sortValue
</syntaxhighlight>
: (sort key)
: comes from {value of the field/s being sorted on}, for special "f" level is {unique id}
; data
: copy of all required data from Search Result service (final level only)
; lowerLevelCount
: number of records in the next level that match this sortValue, if present on the final sortField level means a special "f" exists for this sortValue


== SortedData ==
* partition key: sortResultIdLevelOrdValue
* sort key: dataId
* sortResultIdLevelOrdValue: is {sortResultIdLevelOrd}_{value}
* links multiple dataIds with the same value to their sorted record in TempStringSort/TempNumericSort


=== Fields ===
= Sorting Data That Has a Currency =


; sortResultId
* We want sortResult service to be able to sort by a converted amount, so client cannot perform conversions
: (partition key)
* Have a find data field that returns the base value and currency, another findData that returns conversion to a set currency, this will allow for sorting etc
; sortId
: (sort key)
: numeric value for this records location in sort results
; data
: copy of all required data from Search Result service (final level only)


= Notes =
= Notes =
Line 104: Line 108:
* This service handles pagination of results
* This service handles pagination of results
* ComplexFilter stores unique ids only for a filter, [[Service - Search Result]] takes results from ComplexFilter and adds all data client might need. Sort Result service copies the data from Search Result and structures it for sorted results
* ComplexFilter stores unique ids only for a filter, [[Service - Search Result]] takes results from ComplexFilter and adds all data client might need. Sort Result service copies the data from Search Result and structures it for sorted results
* If we have trouble with incorrect sorts when we concatenate unique key on sortValue for string types, we could bump the data into a final level like we do with numeric final level results
= (probably delete - change Data to be sorted simply) Pagination =
Because of the multi-level structure of the SortResultData tables pagination becomes harder, we need to recurse through levels to know how many records have been counted.
If we have already sent a page of data to the client and the client clicks next or previous we could have the client send which data record was the last record, and use this as a starting point to find the next page of data.
If the client clicks to an arbritrary page it is more complex, we might need to pull a list of all 1st level results, add lowerLevelCount until we find which 1st level result to begin the page results from


= Ideas =
= Ideas =

Latest revision as of 10:18, 25 December 2022

Overview

Service that handles sorted results that come from the Service - Search Result service. Sorted results are stored/cached so subsequent requests do not need to generate the sorted results again.

Repository

https://bitbucket.org/stb_vit/sortresult_main/src/master/

DynamoDB tables

Standard Config Table Per Service

Configuration tags

{
	configKey: "SearchType",
	configTag: "xx" // {eg: sellOffer/Product/VariantProduct etc..}
	configValue: {
		searchResultServiceName: "xx" // {service name of searchResult service that handles this type}
	}
},

Standard WebSocketTask Per Service

SortResultMain

{
	sortResultId: "xx", // main element for one set of search results, comes from {searchType}_{filterMainId}
	requiredData: {}, // same as request
	sortFields: [], // same as request
	requestProperties: {}, // same as request
	createTime: currentTime.getTime(),
	expiryTime: expiryTime.getTime(),
}
  • partition key: sortResultId
  • sort key: {none}
  • sortResultId: searchId + "_" + sortFieldsHash
  • sortFieldsHash: Strip out any sortFields elements after a random element is found, as they are unused. can have multiple sort fields, so we hash them to create the sortFieldsHash unique key

SortResultData

{
	sortResultId: "xx", 
	sortId: ##, // numeric increment for sorting
	dataId: "xx", unique id for the data record, from Search Result service
	data: {}, // all required data from Search Result service
}
  • partition key: sortResultId
  • sort key: sortId

TempStringSort

{
	sortResultIdLevelOrd: "xx", 
	value: "xx",
}
  • partition key: sortResultIdLevelOrd
  • sort key: value
  • sortResultIdLevelOrd: is {sortResultId}_{sortLevel}_{previous sort levels order}

TempNumericSort

{
	sortResultIdLevelOrd: "xx", 
	value: "xx"
}
  • partition key: sortResultIdLevelOrd
  • sort key: value
  • sortResultIdLevelOrd: is {sortResultId}_{sortLevel}_{previous sort levels order}

TempSortDataId

{
	sortResultIdLevelOrdValue: "xx", 
	dataId: "xx"
}
  • partition key: sortResultIdLevelOrdValue
  • sort key: dataId
  • sortResultIdLevelOrdValue: is {sortResultIdLevelOrd}_{value}
  • links multiple dataIds with the same value to their sorted record in TempStringSort/TempNumericSort

Sorting Data That Has a Currency

  • We want sortResult service to be able to sort by a converted amount, so client cannot perform conversions
  • Have a find data field that returns the base value and currency, another findData that returns conversion to a set currency, this will allow for sorting etc

Notes

  • The data stored here should include everything the client request might need to render results to the user, so no additional calls are needed (eg all possible media that might be shown as a thumbnail, and how likely that thumbnail would be shown)(eg pricing info min price/max price/most common sold price/etc)
  • Client uses sortResultId to pull results, can also request ascending or descending
  • This service handles pagination of results
  • ComplexFilter stores unique ids only for a filter, Service - Search Result takes results from ComplexFilter and adds all data client might need. Sort Result service copies the data from Search Result and structures it for sorted results

Ideas

  • date is an interesting sort field, not really used in browse results but would be used a lot in other datasets, it is a filter so could be placed in the complexfilter, but is also something that might change regularly and is based on ordered results, so might be more efficient applied as a sort field in the SortResults, and could filter it there -> my thinking is just treat as a filter and sort separately, could limit changes in filters using date fields so not too many sets of data get generated, eg by fixing requests to set day timestamps.
  • There is some large scale put into DynamoDB commands in this service, might be improved using BatchWriteItem, or improving async code.
  • SortResults defines its own expiry date (might not match ComplexFilter/Search Result expiry dates), so Search Result service must query Sort Result to see if have active results, if expired Sort Result removes its data, Search Result then checks its data/expiry. More fancy: Sort Result returns date expired but does not delete data until Search Result finishes its tasks, if Search Result fails could return Sort Result's old data, and/or push back Sort Result's expiry date.

See also

Working documents

Working_documents - Sort Result