红帽全球峰会第 155 章 Ignite Compute 组件
作为 Camel 2.17 版提供
Ignite Compute 端点是一个 camel-ignite 端点，它允许您传递一个 IgniteCallable、IgniteCallable、IgniteRunnable、IgniteClosure 或它们的集合来在集群中运行 计算操作。
此端点仅支持制作者。
端点 URI 的主机部分是符号链接端点 ID，它不用于任何目的。
端点试图运行作为计算作业在 IN 消息正文中传递的对象。根据执行类型，它需要不同的有效负载类型。
155.1. 选项
Ignite Compute 组件支持下面列出的 4 个选项。
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| ignite (producer) | 设置 Ignite 实例。 | Ignite | |
| configurationResource (producer) | 设置从中加载配置的资源。它可以是： URI、String (URI)或 InputStream。 | 对象 | |
| igniteConfiguration (producer) | 允许用户设置程序化 IgniteConfiguration。 | IgniteConfiguration | |
| resolveProperty Placeholders (advanced) | 启动时，组件是否应自行解析属性占位符。只有 String 类型的属性才能使用属性占位符。 | true | 布尔值 |
Ignite Compute 端点使用 URI 语法配置：
ignite-compute:endpointId
ignite-compute:endpointId使用以下路径和查询参数：
155.1.1. 路径名(1 参数)：
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| endpointId | 必需 端点 ID （不使用）。 | 字符串 |
155.1.2. 查询参数(8 参数)：
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| clusterGroupExpression (producer) | 一个表达式，用于返回 IgniteCompute 实例的 Cluster Group。 | ClusterGroupExpression | |
| computeName (producer) | 计算作业的名称，将通过链接 IgniteComputewithName （字符串）进行设置。 | 字符串 | |
| executionType (producer) | 执行所需的 计算操作。可能的值有：CALL, BROADCAST, APPLY, EXECUTE, RUN, AFFINITY_CALL, AFFINITY_RUN.组件需要不同的有效负载类型，具体取决于操作。 | IgniteComputeExecution Type | |
| propagateIncomingBodyIfNo ReturnValue (producer) | 如果底层 Ignite 操作的返回类型为 void，则设置是否传播传入的正文。 | true | 布尔值 |
| taskName (producer) | 任务名称，仅适用于使用链接 IgniteComputeExecutionTypeEXECUTE 执行类型。 | 字符串 | |
| timeoutMillis (producer) | 触发的作业的超时间隔（以毫秒为单位），将通过链接 IgniteComputewithTimeout (long)设置。 | Long | |
| treatCollectionsAsCache Objects (producer) | 设置是否将集合视为缓存对象，还是作为项目集合来插入/更新/计算等。 | false | 布尔值 |
| 同步 （高级） | 设置同步处理是否应当严格使用，还是允许 Camel 使用异步处理（如果受支持）。 | false | 布尔值 |
155.1.3. 预期的有效负载类型
每个操作都需要指定类型：
| 操作 | 预期有效负载 |
|---|---|
| CALL | 可识别或一个可识别的 IgniteCallable 集合。 |
| BROADCAST | IgniteCallable, IgniteRunnable, IgniteClosure。 |
| APPLY | IgniteClosure. |
| 执行 | ComputeTask, Class<? 扩展 ComputeTask> 或代表参数的对象（如果 taskName 选项不为空）。 |
| 运行 | 系列 IgniteRunnables 或单个 IgniteRunnable。 |
| AFFINITY_CALL | IgniteCallable. |
| AFFINITY_RUN | IgniteRunnable. |
155.1.4. 使用的标头
此端点使用以下标头：
| 标头名称 | 常数 | 预期类型 | 描述 |
|---|---|---|---|
| CamelIgniteComputeExecutionType | IgniteConstants.IGNITE_COMPUTE_EXECUTION_TYPE | IgniteComputeExecutionType enum | 允许您动态更改计算操作以进行执行。 |
| CamelIgniteComputeParameters | IgniteConstants.IGNITE_COMPUTE_PARAMS | 任何对象或集合对象。 | 适用于 APPLY 的参数、BROADCAST 和 EXECUTE 操作。 |
| CamelIgniteComputeReducer | IgniteConstants.IGNITE_COMPUTE_REDUCER | IgniteReducer | 为 APPLY 和 CALL 操作减少。 |
| CamelIgniteComputeAffinityCacheName | IgniteConstants.IGNITE_COMPUTE_AFFINITY_CACHE_NAME | 字符串 | AFFINITY_CALL 和 AFFINITY_RUN 操作的关联性缓存名称。 |
| CamelIgniteComputeAffinityKey | IgniteConstants.IGNITE_COMPUTE_AFFINITY_KEY | 对象 | AFFINITY_CALL 和 AFFINITY_RUN 操作的关联性密钥。 |
'%20d='M201.5%20305.5c-13.8%200-24.9-11.1-24.9-24.6%200-13.8%2011.1-24.9%2024.9-24.9%2013.6%200%2024.6%2011.1%2024.6%2024.9%200%2013.6-11.1%2024.6-24.6%2024.6zM504%20256c0%20137-111%20248-248%20248S8%20393%208%20256%20119%208%20256%208s248%20111%20248%20248zm-132.3-41.2c-9.4%200-17.7%203.9-23.8%2010-22.4-15.5-52.6-25.5-86.1-26.6l17.4-78.3%2055.4%2012.5c0%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.3%2024.9-24.9s-11.1-24.9-24.9-24.9c-9.7%200-18%205.8-22.1%2013.8l-61.2-13.6c-3-.8-6.1%201.4-6.9%204.4l-19.1%2086.4c-33.2%201.4-63.1%2011.3-85.5%2026.8-6.1-6.4-14.7-10.2-24.1-10.2-34.9%200-46.3%2046.9-14.4%2062.8-1.1%205-1.7%2010.2-1.7%2015.5%200%2052.6%2059.2%2095.2%20132%2095.2%2073.1%200%20132.3-42.6%20132.3-95.2%200-5.3-.6-10.8-1.9-15.8%2031.3-16%2019.8-62.5-14.9-62.5zM302.8%20331c-18.2%2018.2-76.1%2017.9-93.6%200-2.2-2.2-6.1-2.2-8.3%200-2.5%202.5-2.5%206.4%200%208.6%2022.8%2022.8%2087.3%2022.8%20110.2%200%202.5-2.2%202.5-6.1%200-8.6-2.2-2.2-6.1-2.2-8.3%200zm7.7-75c-13.6%200-24.6%2011.1-24.6%2024.9%200%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.1%2024.9-24.6%200-13.8-11-24.9-24.9-24.9z'/%3e%3c/svg%3e){kind=small}