Amazon Forecastを組み合わせたSAPでの販売予測

SELECT P~MATNR P~ERDAT SUM( P~KWMENG )
       FROM VBAK AS K INNER JOIN VBAP AS P ON K~VBELN = P~VBELN INTO TABLE IT_SALES_DATA WHERE P~MATNR IN ('MZ-FG-C950','MZ-FG-C900') GROUP BY P~MATNR P~ERDAT.

LOOP AT IT_SALES_DATA.
  DATA S_DEMAND TYPE STRING.
  S_DEMAND = IT_SALES_DATA-KWMENG.
  DATA S_DATE TYPE STRING.
  CONCATENATE IT_SALES_DATA-ERDAT+0(4) IT_SALES_DATA-ERDAT+4(2) IT_SALES_DATA-ERDAT+6(2) INTO S_DATE SEPARATED BY '-'.
  CONCATENATE IT_SALES_DATA-MATNR ',' S_DEMAND ',' S_DATE  INTO LS_FILE_TABLE.
  APPEND LS_FILE_TABLE TO LT_FILE_TABLE.
ENDLOOP.

if ('Authorization' not in event['headers']):
        # User ID Password not provided
        return { "statusCode": 401,"isBase64Encoded" : False }
else:
    secret_name = "<secret name>"
    region_name = "<region id>"
    # Create a Secrets Manager client
    session = boto3.session.Session()
    client=session.client(service_name='secretsmanager',region_name=region_name)

    # Get secret from secrets manager
    get_secret_value_response = client.get_secret_value(SecretId=secret_name)  
    secret = json.loads(get_secret_value_response['SecretString'])

    # Get credentials from authorization header and decode to string
    userdet= event['headers']['Authorization'].split()[1]
    userdet = base64.b64decode(userdet).decode("utf-8")

    # Compare credentials
    if (secret ["<UserName>"] != userdet.split(":")[1]):
       # Password Not Matched
       return {"statusCode": 401", isBase64Encoded" : False}
    else:
	     # Password Matched, Authorization successful

itemid = event['queryStringParameters']['item_id']
fromdate = event['queryStringParameters']['from_date']
todate = event['queryStringParameters']['to_date']

response = forecastclient.query_forecast(
                  ForecastArn='<Replace with your forcastARN>',
                  StartDate = from_date+'T00:00:00',
                  EndDate = to_date+'T00:00:00',
                  Filters = {
                      'item_id' : item_id
                  }
)

[
  {
    "I": "string",
    "D": "string",
    "ME": "string",
    "P10": "string",
    "P50": "string",
    "P90": "string"
  }
]

result = [];
    for num, res in enumerate(response['Forecast']['Predictions']['mean']):
           data = {}
           data['I'] = itemid
           data['D'] = res['Timestamp'][0:10]
           data["ME"] =  str(round(response['Forecast']['Predictions']['mean'][num]['Value'],2))
           data["P10"] = str(round(response['Forecast']['Predictions']['p10'][num]['Value'],2))
           data["P50"] = str(round(response['Forecast']['Predictions']['p50'][num]['Value'],2))
           data["P90"] = str(round(response['Forecast']['Predictions']['p90'][num]['Value'],2))
           data["P99"] = str(round(response['Forecast']['Predictions']['p99'][num]['Value'],2))
           result.append(data)

return {
            "statusCode": 200,
            "isBase64Encoded" : False,
            "body": json.dumps(result),
            "headers" : { 'Content-Type' : 'application/json' },
            "multiValueHeaders" : {}
}

DATA HTTP_CLIENT TYPE REF TO IF_HTTP_CLIENT.

* HTTP Client
CL_HTTP_CLIENT=>CREATE_BY_DESTINATION(
      EXPORTING
        DESTINATION              = '<RFC Destination Created>'
      IMPORTING
        CLIENT                   = HTTP_CLIENT
      EXCEPTIONS
        ARGUMENT_NOT_FOUND       = 1
        DESTINATION_NOT_FOUND    = 2
        DESTINATION_NO_AUTHORITY = 3
        PLUGIN_NOT_ACTIVE        = 4
        INTERNAL_ERROR           = 5
        OTHERS                   = 6
        ).

DATA URI TYPE STRING.

* FROMDATE and TODATE in YYYY-MM-DD format
CONCATENATE '/<API Gateway stage>?item_id=' SELECTEDITEM 'andfrom_date=' FROMDATE 'andto_date=' TODATE INTO URI.
CONDENSE URI.

CL_HTTP_UTILITY=>SET_REQUEST_URI( EXPORTING REQUEST = HTTP_CLIENT->REQUEST URI = URI ).

DATA: REST_CLIENT TYPE REF TO CL_REST_HTTP_CLIENT.

CREATE OBJECT REST_CLIENT EXPORTING IO_HTTP_CLIENT = HTTP_CLIENT.

* Make GET call
  TRY.
    REST_CLIENT->IF_REST_CLIENT~GET( ).
  CATCH CX_REST_CLIENT_EXCEPTION INTO DATA(LO_EXCEPTION).
      DATA(LV_MSG) = `HTTP GET failed: ` Andand LO_EXCEPTION->GET_TEXT( ).
  ENDTRY.

* Get Response
  DATA(LO_RESPONSE) = REST_CLIENT->IF_REST_CLIENT~GET_RESPONSE_ENTITY( ).
  DATA(LV_HTTP_STATUS) = LO_RESPONSE->GET_HEADER_FIELD( '~status_code' ).

* Check status Code
  IF LV_HTTP_STATUS NE 200.
    DATA(LV_REASON) = LO_RESPONSE->GET_HEADER_FIELD( '~status_reason' ).
    WRITE: LV_HTTP_STATUS.
    EXIT.
  ENDIF.

* Get JSON Data from response
  DATA(LV_JSON_DATA) = LO_RESPONSE->GET_STRING_DATA( ).

TYPES : BEGIN OF INNERMOST,
            I   TYPE STRING,
            D   TYPE STRING,
            ME  TYPE STRING,
            P10 TYPE STRING,
            P50 TYPE STRING,
            P90 TYPE STRING,
            P99 TYPE STRING,
          END OF INNERMOST.

  TYPES : PREDICTIONS TYPE STANDARD TABLE OF INNERMOST WITH DEFAULT KEY.
  DATA PREDICT TYPE PREDICTIONS.
  DATA WA TYPE INNERMOST.

  /UI2/CL_JSON=>DESERIALIZE( EXPORTING JSON = LV_JSON_DATA PRETTY_NAME = /UI2/CL_JSON=>PRETTY_MODE-CAMEL_CASE CHANGING DATA = PREDICT ).

  LOOP AT PREDICT INTO WA .
    WRITE: / WA-I UNDER 'Material' , WA-D UNDER 'Date', WA-ME UNDER 'Mean', WA-P50 UNDER 'P50', WA-P90 UNDER 'P90', WA-P99 UNDER 'P99'.
  ENDLOOP.