OR Return Processor ECS Infrastructure¶
Components¶
Component |
Description |
Ref |
|---|---|---|
<<Config Service>> |
Configuration details used for OR Return Processor. |
|
<<SNS>> |
SNS for Cloudwatch Alarm. |
|
<<CLOUDWATCH LOG GROUP>> |
CLOUDWATCH LOG to show logger messages . |
|
<<SSM>> |
SSM for Online Returns Service Call. |
|
<<SSM>> |
SSM for Online Returns Product V1 Service Call. |
|
<<SSM>> |
SSM for Online Returns Price Service Call. |
|
<<RDS>> |
RDS to save scanned products and to save min of barcode fetched from product service. |
|
<<KAFKA SERVER>> |
Kafka Broker Name. |
|
<<KAFKA TOPIC>> |
kafka Topic name to consume message from salse adapter. |
|
<<Ecstask>> |
This Task is used to fetch aggregated scanned product location wise and send to stock transfer api. |
Configuration(from config service)¶
Config File Name |
|---|
storepick-online-returns.json |
Value:
config = {
"DATABASE": "online_returns",
"MORI_BASE_URL": "https://api.morrisons.com",
"PRODUCTELASTICSEARCH_URL": "product/v1/items/",
"STOCKTRANSFERSCREATE_URL": "stock/v2/transfers",
"STOCK_TRANSFER_REQUEST": {
"VIRTUAL_LOC_PREFIX": "8",
"USER_NAME": "StorePickUser",
"CONTAINER_ID": 1
},
"STOCKADJUSTMENTCREATE_URL": "stock/v2/locations",
"GETITEMPRICE_URL": "price/v2/locations",
"GETLOCATION_URL": "location/v2/stores",
"OSP_BASE_URL": "https://api.morrisons.osp.tech/externalapi",
"OSP_USER_URL": "v4/users/find-by-username",
"CALL_LOCATION_V2": True,
"STOCK_ADJUSTMENT_REASON": "31",
"STOCK_ADJUSTMENT_LIMIT": 100,
"STOCK_TRANSFER_LIMIT": 1000,
"NO_OF_DAYS_FOR_HISTORY": 2,
"IS_CATCHWEIGHT_REQUIRED": False,
"BIG_QUERY_DATASET": "store_pick",
"BIG_QUERY_TABLE": "online_returns",
"BIG_QUERY_LIMIT": 100,
"PRICE_V2_CACHE_MAX_LENGTH": 99999,
"PRICE_V2_CACHE_TTL": 100,
"API_RETRY_COUNT": 5,
"API_RETRY_EXPONENTIAL_BACKOFF": 1000,
"RDS_RETRY_COUNT": 5,
"KAFKA": {
"CONSUMER_GROUP_ID": "return_products_from_sales_adapter",
"BOOTSTRAP_SERVER": "b-2.msk-euw1-prd-digital-v.7a52by.c1.kafka.eu-west-1.amazonaws.com:9094,b-1.msk-euw1-prd-digital-v.7a52by.c1.kafka.eu-west-1.amazonaws.com:9094,b-3.msk-euw1-prd-digital-v.7a52by.c1.kafka.eu-west-1.amazonaws.com:9094",
"TOPICS": [
"kafka-euw1-$ENV-digital-storepick-online-returns-sales-items"
],
"READ_MAX_MESSAGES": 10000,
"TIME_OUT": 20
},
"STORE_ID_LIST": [],
"AUTHORIZED_USER_ROLES": [
"shift_manager",
"driver_manager"
]
}
SNS Topic name for Cloudwatch alarm¶
Environment |
RDS |
|---|---|
dev |
sns-euw1-dev-storepick-online-return-processor-002-001-Alarm |
sit |
sns-euw1-sit-storepick-online-return-processor-002-001-Alarm |
prd |
sns-euw1-prd-storepick-online-return-processor-002-001-Alarm |
Cloudwatch Log Group Name¶
Environment |
Cloudwatch Log Group |
|---|---|
dev |
clg-euw1-dev-storepick-online-return-processor-002 |
sit |
clg-euw1-sit-storepick-online-return-processor-002 |
prd |
clg-euw1-prd-storepick-online-return-processor-002 |
SSM for online returns¶
SSM Name |
|---|
storepick_online_returns_secret |
Value:
{
"apikey": "__EXISTS__",
"resourceArn": "__EXISTS__",
"secreteArn": "__EXISTS__",
"hostUrl": "__EXISTS__",
"userName": "__EXISTS__",
"password": "__EXISTS__"
}
SSM for Product V1 Service¶
SSM Name |
|---|
storepick_product_service_secret |
Value:
{
"API_KEY": "__EXISTS__",
"AUTHORISATION": "__EXISTS__",
}
SSM for price V2 Service¶
SSM Name |
|---|
storepick_price_service_secret |
Value:
{
"API_KEY": "__EXISTS__",
"AUTHORISATION": "__EXISTS__",
}
AWS RDS¶
Environment |
RDS |
|---|---|
dev |
rds-euw1-dev-digital-apsql-onl-returns-002 |
sit |
rds-euw1-sit-digital-apsql-onl-returns-002 |
prd |
rds-euw1-prd-digital-apsql-onl-returns-002 |
KAFKA SERVER¶
Environment |
RDS |
|---|---|
dev |
b-1.picktask-test.k8bixh.c5.kafka.eu-west-1.amazonaws.com:9094,b-2.picktask-test.k8bixh.c5.kafka.eu-west-1.amazonaws.com:9094,b-3.picktask-test.k8bixh.c5.kafka.eu-west-1.amazonaws.com:9094 |
sit |
b-2.msk-euw1-sit-digital-v.ogiidf.c1.kafka.eu-west-1.amazonaws.com:9094,b-3.msk-euw1-sit-digital-v.ogiidf.c1.kafka.eu-west-1.amazonaws.com:9094,b-1.msk-euw1-sit-digital-v.ogiidf.c1.kafka.eu-west-1.amazonaws.com:9094 |
prd |
b-2.msk-euw1-prd-digital-v.7a52by.c1.kafka.eu-west-1.amazonaws.com:9094,b-1.msk-euw1-prd-digital-v.7a52by.c1.kafka.eu-west-1.amazonaws.com:9094,b-3.msk-euw1-prd-digital-v.7a52by.c1.kafka.eu-west-1.amazonaws.com:9094 |
KAFKA TOPIC¶
Environment |
RDS |
|---|---|
dev |
kafka-euw1-dev-digital-storepick-online-returns-sales-items |
sit |
kafka-euw1-sit-digital-storepick-online-returns-sales-items |
prd |
kafka-euw1-prd-digital-storepick-online-returns-sales-items |
AWS ECS Task¶
Environment |
ECS Task |
|---|---|
dev |
storepick-ecs-online-return-processor-dev-002 |
sit |
storepick-ecs-online-return-processor-sit-002 |
prd |
storepick-ecs-online-return-processor-prd-002 |