Skip to main content
Version: Next

File

FileSinkConnector: Writes File file from EventMesh​

  1. Start your EventMesh Runtime.
  2. Enable sinkConnector and check sink-config.yml.
  3. Started FileConnectServer, It will subscribe to the topic defined in pubSubConfig.subject in the EventMesh Runtime, And write the data to the path located : connectorConfig.topic/Year/Month/Day ; the file named:【 connectorConfig.topic + Current time Hour (24 hours) + timestamp 】.
  4. Using the Topic specified in pubSubConfig.subject, send a message to EventMesh, which you will persist in the file.
# Common configuration
pubSubConfig:
    meshAddress: 127.0.0.1:10000
    subject: TopicTest
    idc: FT
    env: PRD
    group: fileSink
    appId: 5031
    userName: fileSinkUser
    passWord: filePassWord
connectorConfig:
    connectorName: fileSink
    #topic Generally, the configuration is the same as that of pubSubConfig.subject. The generated file name contains the configuration value of this property
    topic: TopicTest

FileSourceConnector: Read from File to EventMesh​

  1. Start your EventMesh Runtime.
  2. Enable sinkConnector and check source-config.yml.
  3. Started FileConnectServer, It sends the data read from connectorConfig.filePath to pubSubConfig.subject in the EventMesh Runtime.
  4. The append to the file content is recognized, and you receive the message in EventMesh.
# Common configuration
pubSubConfig:
    meshAddress: 127.0.0.1:10000
    subject: TopicTest
    idc: FT
    env: PRD
    group: fileSource
    appId: 5032
    userName: fileSourceUser
    passWord: filePassWord
connectorConfig:
    connectorName: fileSource
    # Source file address
    filePath: userFilePath

Special note: System.in and System.out are used if the source file or import file cannot be retrieved.