Testing Streaming Functions

Testing Streaming Functions

Send Test Data to Source Data Model

Ingest test data into the source data model to trigger the function.

Need Help Ingesting Data?

Check out the Ingesting Data section of the documentation.

Check CLI Output

Check the terminal output to see if the streaming function has processed the data correctly. You should see the following message in your terminal:

Received SourceDataModel -> DestinationDataModel 1 message(s)
Don't See This Message?

Here are some troubleshooting tips:

  • Make sure you have the correct source and destination data models in your function file.

  • Save the function file after making changes.
  • Double check your function logic for any errors.

  • You can also run moose logs --tail to see logs in real-time.

Inspect Destination Data Model Table

After the streaming function processes the data, check the destination table in the database to see if the data has been transformed correctly.