LogoLogo
Home
Core Platform
Core Platform
  • Introduction
    • Overview
    • Use Cases
    • Architecture
    • Built with ML & AI
    • Quick Start
  • Examples
    • Training Examples
      • API Flow Examples
      • Microservice Examples
      • UI Example
      • Exercise: Hello World API
      • Exercise: Test State
      • Exercise: Test UI
    • Exercise: To-do List
      • To-do List Runner
      • To-do List Gateway
      • To-do List UI
      • To-do List Query
  • Troubleshooting
    • Rierino Packages
    • Release Notes
    • Useful Checks
    • Error Codes
  • Devops
    • Overview
    • API Flows
      • Using the Saga Screen
      • Defining a Saga
      • Configuring Saga Steps
        • Event Step
        • Transform Step
          • Transform Classes
        • Condition Step
          • Condition Classes
        • Step Link
      • Injecting Variables
    • Microservices
      • Runners
        • Using the Runner Screen
        • Defining a Runner
        • Managing Runner Settings
        • Adding Runner Elements
        • Deploying Runners
          • Spring Runners
          • Samza Runners
          • Camel Runners
      • Elements
        • Systems
        • State Managers
          • Typical Use Cases
          • State Data Structure
          • Local States
            • In-Memory Map
            • Caffeine Cache
            • Samza Based
            • Lucene Based
            • Single File
            • Multiple Files
            • Selected IDs Map
            • Indexed Map
          • Shared States
            • MongoDB Collection
            • Jooq (SQL) Table
            • Redis Map
            • Couchbase Collection
            • Elasticsearch Index
            • Elasticsearch Joined
            • Etcd Namespace
          • Specialized States
            • CRUD Service
            • Odata Service
          • State Coordinators
            • Lazy Cache Coordinator
            • Event Store Coordinator
            • Write thru Coordinator
          • Loading Strategies
          • ID Generators
        • Listeners
        • Query Managers
          • MongoDB
          • Elasticsearch
          • Lucene
          • SQL Based
          • Odata Service
        • Handlers
          • Core Handlers
            • Write Data
            • Read Data
            • Query Data
            • Apply Rules
            • Call Rest API
            • Generate Text/Html
            • Parse Html
            • Generate Secrets
            • Orchestrate User Task
            • Perform File Operation
            • Run Shell Command
            • Send/Receive Emails
          • Custom Code Handlers
            • Run Scripts
            • Run Java Code
            • Run Java Package
          • Flow Handlers
            • Orchestrate Saga
            • Loop Each Entry
            • Run Multiple Steps
            • Buffer Payloads
            • Merge Parallel Steps
            • Log Event
            • Send Event
            • Validate Event
            • Transform Event
            • Perform DB Transaction
            • Trigger Runner Command
            • Do Nothing
            • Modify Role Data
            • Enrich Role Data
            • Convert Pulse to Journal
          • Gateway Handlers
            • Authenticate
              • No Authentication
              • State Based
              • Keycloak Based
            • Sessionize
          • Specialized Handlers
            • Apply Advanced Rules
            • Calculate Real-time Metrics
            • Score ML Models
            • Score LangChain Models
            • Service MCP Requests
            • Service A2A Requests
            • Consume Web of Things
            • Perform Text Embedding
            • Run Python Procedure
            • Generate Excel
            • Generate PDF
            • Call SOAP API
            • Integrate with Camel
        • Actions
        • Streams
          • Kafka Topic
          • CDC Feed
          • Camel Component
        • Roles
        • Generic Settings
        • Global Settings
      • Deployments
        • Defining a Deployment
        • Alternative Loaders
    • Gateway & Security
      • Gateway Servers
        • Gateway Systems
        • Gateway Channels
        • Gateway Services
        • Gateway Tokens
      • APIs
        • OpenAPI Specification
        • Response Formats
    • Administration
      • Managing Deployments
      • Sending Commands
      • Streaming Messages
      • Migrating Assets
    • Batch Tasks
      • Python Processes
      • Python Iterators
      • Python Processors
    • Pro-Code
      • Custom Handlers
      • Custom State Managers
      • Custom Query Managers
      • Custom CDC Managers
  • Design
    • Overview
    • User Interface
      • Apps
      • UIs
        • Listers
        • Widgets
          • Value Widgets
          • Array Widgets
          • Object Widgets
          • Indirect Widgets
          • Atom Widgets
        • Menus
          • Lister Menu Actions
          • Selection Menu Actions
          • Editor Menu Actions
          • Widget Menu Actions
          • Custom Menu Actions
          • RAI Menu Actions
        • Extended Scope
          • Conditional Display
          • Data Context
          • Extra Data
          • Default Item
          • Extra Events
      • Options
      • Translations
      • Icons
      • Styles
      • Components
    • API Mapping
    • Data Schema
      • Common Data
  • Configuration
    • Overview
    • Queries
      • Query Types
      • Query Platforms
        • MongoDB Queries
        • Odata Queries
        • SQL Queries
        • Elasticsearch Queries
        • Lucene Queries
        • Siddhi Queries
    • Business Rules
      • Drools Rules
    • Dynamic Handlers
  • Data Science
    • Overview
    • ML Models
      • Scheduler Platforms
        • Airflow Scheduler
    • GenAI Models
    • MCP Servers
    • Complex Event Processing
      • Siddhi Data Flows
    • Data Visualizations
    • Customizations
  • EXTENSIONS
    • JMESPath
    • Handlebars
Powered by GitBook

© Rierino Software Inc. 2025. All rights reserved.

On this page
  • rierino_runner.iterator.NumberIterator
  • rierino_runner.iterator.DataIterator
  • rierino_runner.iterator.FSIterator
  • rierino_runner.iterator.IOIterator
  • rierino_runner.iterator.RestIterator
  • rierino_runner.iterator.JavaIterator
  1. Devops
  2. Batch Tasks

Python Iterators

Iterators are used by IterateProcess to produce loops of Processor calls

Iterators available out of box for execution are listed on this page. It is also possible to create new iterators using rierino_runner.Iterator as the base class.

rierino_runner.iterator.NumberIterator

This iterator produces and iterates through sequential numbers.

rierino_runner.iterator.DataIterator

This iterator translates a data array into individual records and loops through them.

Parameter
Definition
Example
Default

element

Element in received payload to iterate on

data.list

-

rierino_runner.iterator.FSIterator

This iterator goes through list of files within a file system and returns their details as a loop.

Parameter
Definition
Example
Default

system

Name of system in connections to connect to

fs_default

-

path

Path on file system to list

/media

-

pathElement

Json path for the sub-path in input payload to append to path

data.folder

-

withPrefix

Whether path includes a prefix (after last / character)

true

-

format

Type of data to be produced for discovered files (full, name, file)

path

file

dedupe

Whether duplicates - based on prefix - should be removed (order, all)

order

-

orderRegex

Regex to extract "order" number from file name

-

-

download

Whether files should be downloaedd

true

-

recursive

Whether sub directories should be also iterated

true

-

withDirs

Whether directories should be included in results

true

-

rierino_runner.iterator.IOIterator

This iterator reads records from a database or file and iterates through them as a loop, utilizing rierino_util.IOUtil.

Parameter
Definition
Example
Default

system

Name of system in connections to connect to

mongo_master

-

input

Input parameters required for reading data from the system

{database: "master", collection: "product"}

-

rierino_runner.iterator.RestIterator

This iterator makes calls to a REST API and passes responses after each call as a loop.

Parameter
Definition
Example
Default

system

Name of system in connections to connect to

erp

-

method

Request method

GET

-

url

Request URL

/ListProducts

-

headers

Headers to pass on in request

{}

-

pattern

Jmespath pattern to apply to input payload for request contents

{product: data}

-

retries

Number of retries if the REST call fails

3

0

rierino_runner.iterator.JavaIterator

This iterator is only applicable when called through Java Py4JEventHandler, allowing hook calls to the Java runner without requiring explicit REST API calls.

Parameter
Definition
Example
Default

pattern

Jmespath pattern to apply to input payload for request contents

{product: data}

-

meta

Event metadata to pass on to Java runner

-

-

retries

Number of retries if the Java call fails

3

0

PreviousPython ProcessesNextPython Processors

Last updated 4 months ago