async def main(req: func.HttpRequest, starter: str) -> func.HttpResponse:
    """
    Start the execution.

    Args:
        req (func.HttpRequest): To get data from request body pushed by webhook

    Returns:
        func.HttpResponse: Status of Http request process (successful/failed).
    """
    __method_name = inspect.currentframe().f_code.co_name
    try:
        applogger.debug("{} HttpStarter Function Called.".format(LOGS_STARTS_WITH))
        data = get_data_from_request_body(req)
        if data:
            client = df.DurableOrchestrationClient(starter)
            instance_id = await client.start_new(
                req.route_params["functionName"], client_input=data
            )
            applogger.info(
                "{} Started orchestration with ID = '{}'.".format(
                    LOGS_STARTS_WITH, instance_id
                )
            )
            body = "Data Received successfully via Rubrik Webhook."
            return func.HttpResponse(
                body=body,
                status_code=200,
                headers={"Content-Length": str(len(body))},
            )
        else:
            applogger.info("{}(method={})No required data found.".format(LOGS_STARTS_WITH, __method_name))
            body = "No required data found."
            return func.HttpResponse(
                body=body,
                status_code=202,
                headers={"Content-Length": str(len(body))},
            )
    except RubrikException as err:
        body = "Error: {}".format(err)
        return func.HttpResponse(
            body=body,
            status_code=400,
            headers={"Content-Length": str(len(body))},
        )

    Start the execution.

    Args:
        req (func.HttpRequest): To get data from request body pushed by webhook

    Returns:
        func.HttpResponse: Status of Http request process (successful/failed).
    
Solutions/RubrikSecurityCloud/Data Connectors/RubrikWebhookEvents/RubrikHttpStarter/__init__.py