AWS Textract component

The aws2-textract component extracts text, forms, tables and invoice fields from documents and images with Amazon Textract.

Scheme: aws2-textract: · Crate: cameleer-cloud · Cargo feature: cloud · Consumer: no · Producer: yes · Apache Camel: AWS Textract

When to use it

• Read invoices and receipts dropped into a bucket and send their fields to an ERP.
• Turn scanned PDFs into text for search or for an LLM.
• Give an AI agent a document-reading tool: the route returns structured fields the model can use.

URI format

aws2-textract://label?operation=...[&options]

The document is the S3 object named by s3Bucket / s3Object (options or headers) or, for the synchronous operations, the body bytes.

Example

Extract invoice fields from every file uploaded to a bucket and queue them as JSON:

- route:
    id: extract-invoices
    from:
      uri: "aws2-s3://scanned-invoices?region={{env:AWS_REGION:us-east-1}}"
      steps:
        - to: "aws2-textract://invoices?region={{env:AWS_REGION:us-east-1}}&operation=analyzeExpense"
        - marshal:
            json: {}
        - to: "aws2-sqs://extracted-invoices?region={{env:AWS_REGION:us-east-1}}&autoCreateQueue=true"

The S3 consumer passes the object content as the body; analyzeExpense returns the Textract response (with ExpenseDocuments and their SummaryFields) as a map.

Rust DSL

ctx.add_routes(|b| {
    b.from("aws2-s3://scanned-invoices?region={{env:AWS_REGION:us-east-1}}")
        .to("aws2-textract://invoices?region={{env:AWS_REGION:us-east-1}}&operation=analyzeExpense")
        .marshal("json")
        .to("aws2-sqs://extracted-invoices?region={{env:AWS_REGION:us-east-1}}&autoCreateQueue=true");
})?;

Options

Common AWS options (region, credentials, endpoint override, proxy) are listed in Cloud credentials.

The synchronous operations return the response map (Blocks or ExpenseDocuments). The start* operations return the job id (also in CamelAwsTextractJobId); the get* operations return the job status and results.

Message headers

Run it with Docker

docker run --rm -e AWS_REGION -e AWS_ACCESS_KEY_ID -e AWS_SECRET_ACCESS_KEY \
  -v "$PWD:/routes:ro" pmsudhi/cameleer run /routes/invoices.camel.yaml

Common questions

How do I process multi-page PDFs?

Use the asynchronous operations: startDocumentAnalysis with s3Bucket / s3Object, keep the job id, then call getDocumentAnalysis until JobStatus is SUCCEEDED.

How do I get only the text lines?

Use detectDocumentText and keep the blocks whose BlockType is LINE, for example with a split on ${body[Blocks]} and a filter.

Related

• AWS S3, AWS Comprehend, AWS Bedrock
• Cloud credentials
• Apache Camel AWS Textract

Found a problem?

If something on this page doesn't match what Cameleer does, or you hit a bug while building with it, please help fix it, whether you are a person or a coding agent: open an issue that describes what you saw, then fork the repository, fix it, add or update a test, run cargo test --workspace, and open a pull request. CONTRIBUTING.md explains the ground rules.