HDFS Connector

< ?xml version="1.0" encoding="UTF-8"?>
            < mule xmlns:tls="http://www.mulesoft.org/schema/mule/tls" xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:scripting="http://www.mulesoft.org/schema/mule/scripting" xmlns:api-platform-gw="http://www.mulesoft.org/schema/mule/api-platform-gw" xmlns:dw="http://www.mulesoft.org/schema/mule/ee/dw" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:hdfs="http://www.mulesoft.org/schema/mule/hdfs" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:apikit="http://www.mulesoft.org/schema/mule/apikit" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:spring="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/apikit http://www.mulesoft.org/schema/mule/apikit/current/mule-apikit.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.mulesoft.org/schema/mule/hdfs http://www.mulesoft.org/schema/mule/hdfs/current/mule-hdfs.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd
http://www.mulesoft.org/schema/mule/ee/dw http://www.mulesoft.org/schema/mule/ee/dw/current/dw.xsd
http://www.mulesoft.org/schema/mule/api-platform-gw http://www.mulesoft.org/schema/mule/api-platform-gw/current/mule-api-platform-gw.xsd
http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/current/mule-scripting.xsd
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd
http://www.mulesoft.org/schema/mule/tls http://www.mulesoft.org/schema/mule/tls/current/mule-tls.xsd">
    < http:listener-config name="keystone-system-httpListenerConfig" host="0.0.0.0" port="8091" doc:name="HTTP Listener Configuration"/>
    < apikit:config name="keystone-system-config" raml="keystone-system.raml" consoleEnabled="false" doc:name="Router" keepRamlBaseUri="true"/>
    < hdfs:config-with-kerberos name="HDFS__Kerberos_Configuration" nameNodeUri="uri" username="username" keytabPath="${mule.home}${file.separator}apps${file.separator}${app.name}${file.separator}classes${file.separator}.keytab" doc:name="HDFS: Kerberos Configuration" >
        < hdfs:configuration-entries>
            < hdfs:configuration-entry key="hadoop.security.key.provider.path">kms://https@username.path.com:93
            < hdfs:configuration-entry key="dfs.encryption.key.provider.uri">kms://https@username.path.com:93
        < /hdfs:configuration-entries>
    < /hdfs:config-with-kerberos>
    < api-platform-gw:api apiName="api-system-keystone-dev" version="1.0.0" flowRef="keystone-system-main" create="true" apikitRef="keystone-system-config" doc:name="API Autodiscovery"/>
    < flow name="keystone-system-main">< http:listener config-ref="keystone-system-httpListenerConfig" path="/api/*" doc:name="HTTP"/>
        < apikit:router config-ref="keystone-system-config" doc:name="APIkit Router"/>
        < exception-strategy ref="keystone-system-apiKitGlobalExceptionMapping" doc:name="Reference Exception Strategy"/>
    < /flow>
    < flow name="keystone-system-console">
        < http:listener config-ref="keystone-system-httpListenerConfig" path="/console/*" doc:name="HTTP"/>
        < apikit:console config-ref="keystone-system-config" doc:name="APIkit Console"/>
    < /flow>
    < flow name="get:/hadoop/hdfs/secure/hr/read:keystone-system-config">
        < flow-ref name="ConfigureHDFS" doc:name="ConfigureHDFS"/>
        < set-variable variableName="HDFSPathToRead" value="#[message.inboundProperties.'http.query.params'.hdfspath]" doc:name="HDFS Path"/>
        < hdfs:read-operation config-ref="HDFS__Kerberos_Configuration" path="#[flowVars.HDFSPathToRead]" doc:name="ReadFileFromHDFS"/>
        < choice-exception-strategy doc:name="Choice Exception Strategy">
            < catch-exception-strategy enableNotifications="false" logException="false" doc:name="Catch Exception Strategy">
                < expression-component doc:name="Expression"> -1) {
	msg = "Missing or Null Payload not Allowed";
} else
{
msg = msg.substring(badRequestException.length());
}
} else if (msg.startsWith(badConnectionException)) {
	msg = msg.substring(badConnectionException.length());

}
payload = msg.replace("\\","\\\\").replace("\"", "\\\"");
]]>< /expression-component>
                < choice doc:name="Choice">
                    < when expression="#[exception.cause.toString().startsWith("org.mule.api.ConnectionException: ")]">
                        < set-property propertyName="http.status" value="#[404]" doc:name="Status - 404"/>
                    < /when>
                    < otherwise>
                        < set-property propertyName="http.status" value="#[500]" doc:name="Status - 500"/>
                    < /otherwise>
                < /choice>
                < dw:transform-message doc:name="Transform Message">
                    < dw:set-payload>< /dw:set-payload>
                < /dw:transform-message>
            < /catch-exception-strategy>
        < /choice-exception-strategy>

    < /flow>
    < flow name="post:/hadoop/hdfs/secure/hr/write:multipart/form-data:keystone-system-config">
        < flow-ref name="ConfigureHDFS" doc:name="ConfigureHDFS"/>
        < set-payload value="#[message.inboundAttachments]" doc:name="Retrieve Attachments"/>
        < set-variable variableName="myMap" value="#[[:]]" doc:name="MyMap"/>

              < foreach doc:name="For Each">
            < logger message="Attachment: #[payload.getName()]" level="DEBUG" doc:name="Logger"/>
            < expression-component doc:name="Expression">< /expression-component>
< /foreach>
        < hdfs:write config-ref="HDFS__Kerberos_Configuration" path="#[flowVars.myMap.hdfspath]" payload-ref="#[flowVars.myMap.fileContents]" doc:name="WriteToHDFS"/>
        < choice-exception-strategy doc:name="Copy_of_Choice Exception Strategy">
            < catch-exception-strategy enableNotifications="false" logException="false" doc:name="Copy_of_Catch Exception Strategy">
                < expression-component doc:name="Copy_of_Expression"> -1) {
	msg = "Missing or Null Payload not Allowed";
} else
{
msg = msg.substring(badRequestException.length());
}
} else if (msg.startsWith(badConnectionException)) {
	msg = msg.substring(badConnectionException.length());

}
payload = msg.replace("\\","\\\\").replace("\"", "\\\"");
]]>< /expression-component>
                < choice doc:name="Copy_of_Choice">
                    < when expression="#[exception.cause.toString().startsWith("org.mule.api.ConnectionException: ")]">
                        < set-property propertyName="http.status" value="#[404]" doc:name="Copy_of_Status - 404"/>
                    < /when>
                    < otherwise>
                        < set-property propertyName="http.status" value="#[500]" doc:name="Copy_of_Status - 500"/>
                    < /otherwise>
                < /choice>
                < dw:transform-message doc:name="Copy_of_Transform Message">
                    < dw:set-payload>< /dw:set-payload>
                < /dw:transform-message>
            < /catch-exception-strategy>
        < /choice-exception-strategy>

    < /flow>
    < apikit:mapping-exception-strategy name="keystone-system-apiKitGlobalExceptionMapping">
        < apikit:mapping statusCode="404">
            < apikit:exception value="org.mule.module.apikit.exception.NotFoundException" />
            < dw:transform-message doc:name="Transform Message">
                < dw:set-payload>< /dw:set-payload>
            < /dw:transform-message>

        < /apikit:mapping>
        < apikit:mapping statusCode="405">
            < apikit:exception value="org.mule.module.apikit.exception.MethodNotAllowedException" />
            < dw:transform-message doc:name="Transform Message">
                < dw:set-payload>< /dw:set-payload>
            < /dw:transform-message>

        < /apikit:mapping>
        < apikit:mapping statusCode="415">
            < apikit:exception value="org.mule.module.apikit.exception.UnsupportedMediaTypeException" />
            < dw:transform-message doc:name="Transform Message">
                < dw:set-payload>< /dw:set-payload>
            < /dw:transform-message>

        < /apikit:mapping>
        < apikit:mapping statusCode="406">
            < apikit:exception value="org.mule.module.apikit.exception.NotAcceptableException" />
            < dw:transform-message doc:name="Transform Message">
                < dw:set-payload>< /dw:set-payload>
            < /dw:transform-message>

        < /apikit:mapping>
        < apikit:mapping statusCode="400">
            < apikit:exception value="org.mule.module.apikit.exception.BadRequestException" />
            < dw:transform-message doc:name="Transform Message">
                < dw:set-payload>< /dw:set-payload>
            < /dw:transform-message>

        < /apikit:mapping>
    < /apikit:mapping-exception-strategy>
    < sub-flow name="ConfigureHDFS">
        < set-variable variableName="krb5Loc" value="${mule.home}${file.separator}apps${file.separator}${app.name}${file.separator}classes${file.separator}krb5.conf" doc:name="Set KRB5 Variable"/>
        < expression-component doc:name="Set System Property">
        < set-variable variableName="HDFS_TrustStore" value="${mule.home}${file.separator}apps${file.separator}${app.name}${file.separator}classes${file.separator}hdfs.ts" doc:name="Set TrustStore"/>
        < expression-component doc:name="Set TrustStore Location">
        < expression-component doc:name="Set TrustStore Password">
    < /sub-flow>
< /mule>