safesoftware/fme-engine-2017

safesoftware/fme-engine-2017 镜像说明

镜像概述

safesoftware/fme-engine-2017是一个独立的FME引擎容器，可监听指定端口接收外部作业请求并执行，适用于需要自动化运行FME工作空间的场景。

核心功能

• 监听容器内7777端口，接收作业请求
• 执行FME工作空间任务
• 支持挂载工作空间目录存储待执行文件
• 支持挂载日志目录输出执行日志

使用场景

• 地理信息数据转换与处理
• ETL任务自动化执行
• 分布式FME作业调度

配置说明

卷挂载

镜像包含两个关键卷：

1. /fmeengine/workspaces：存放待执行的FME工作空间文件
2. /fmeengine/logs：输出作业执行日志

部署示例

Docker Run命令

bash
docker run --rm -p 7777:7777 -v ~/workspaces:/fmeengine/workspaces -v ~/logs:/fmeengine/logs safesoftware/fme-engine-2017

参数说明：

• -p 7777:7777：主机与容器端口映射
• -v ~/workspaces:/fmeengine/workspaces：挂载主机工作空间目录
• -v ~/logs:/fmeengine/logs：挂载主机日志目录

发送作业请求

使用Python脚本FMEEngineClient.py发送请求：

bash
FMEEngineClient.py <host> <port> <FME command line>

脚本代码：

python
# FMEEngineClient.py
import struct
import socket
import sys

if len(sys.argv) != 4:
   print "Usage: " + sys.argv[0] + " <host> <port> <request>"
   exit(1)

TCP_IP = sys.argv[1]
TCP_PORT = sys.argv[2]

keyword_str = 'JOB_SUBMITTER_SERVICE'
request_str = sys.argv[3]

keyword = struct.pack('!i' + str(len(keyword_str)) + 's', len(keyword_str), keyword_str)
request = struct.pack('!i' + str(len(request_str)) + 's', len(request_str), request_str)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((TCP_IP, int(TCP_PORT)))
s.send(keyword)
s.send(request)

data = s.recv(4)
recv_size = struct.unpack('!i', data)[0]
data = s.recv(recv_size)
result_message = struct.unpack('!' + str(recv_size) + 's', data)[0]
print result_message

s.close()

更多示例可参考：https://github.com/safesoftware/fme-standalone-engine