| // camel-k: dependency=camel-azure-storage-blob |
| // |
| // Apache Camel Azure Storage Blob Consumer |
| // |
| import static org.apache.camel.support.processor.idempotent.MemoryIdempotentRepository.memoryIdempotentRepository |
| |
| from('knative:channel/azure-blob') |
| .setHeader('orderId', xpath("/order/@id",String.class)) |
| //use idempotent consumer to process an order only once |
| .idempotentConsumer(header("orderId"), memoryIdempotentRepository(50)) |
| .log('Received:\n${body}') |
| .split() |
| .xpath('/order/item') |
| .setHeader('lineItemId', xpath("/item/@id",String.class)) |
| .setHeader('CamelAzureStorageBlobBlobName', simple('${header.lineItemId}-${header.orderId}.xml')) |
| .log('Uploading Item ${header.CamelAzureStorageBlobBlobName}:\n${body}') |
| .to('azure-storage-blob:{{azure.blob.accountName}}/{{azure.blob.itemsContainerName}}?accessKey=RAW({{azure.blob.accessKey}})&operation=uploadBlockBlob') |
| |
| |
| |
| |
