OR Return Processor ECS Infrastructure

Components

Component

Description

Ref

<<Config Service>>

Configuration details used for OR Return Processor.

Configuration(from config service)

<<SNS>>

SNS for Cloudwatch Alarm.

SNS Topic name for Cloudwatch alarm

<<CLOUDWATCH LOG GROUP>>

CLOUDWATCH LOG to show logger messages .

Cloudwatch Log Group Name

<<SSM>>

SSM for Online Returns Service Call.

SSM for online returns

<<SSM>>

SSM for Online Returns Product V1 Service Call.

SSM for Product V1 Service

<<SSM>>

SSM for Online Returns Price Service Call.

SSM for price V2 Service

<<RDS>>

RDS to save scanned products and to save min of barcode fetched from product service.

AWS RDS

<<KAFKA SERVER>>

Kafka Broker Name.

KAFKA SERVER

<<KAFKA TOPIC>>

kafka Topic name to consume message from salse adapter.

KAFKA TOPIC

<<Ecstask>>

This Task is used to fetch aggregated scanned product location wise and send to stock transfer api.

AWS ECS Task

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