diff --git a/examples/developer_guide/2_2_rabbitmq/README.md b/examples/developer_guide/2_2_rabbitmq/README.md index b9ee797e46..053f4a28a2 100644 --- a/examples/developer_guide/2_2_rabbitmq/README.md +++ b/examples/developer_guide/2_2_rabbitmq/README.md @@ -38,7 +38,7 @@ In a second terminal from the root of the Morpheus repo execute: python examples/developer_guide/2_2_rabbitmq/read_simple.py ``` -This will read from a RabbitMQ exchange named 'logs', and write the results to `/tmp/results.json`. +This will read from a RabbitMQ exchange named 'logs', and write the results to `results.json`. If no exchange named 'logs' exists in RabbitMQ it will be created. By default the `read_simple.py` script will utilize the class-based `RabbitMQSourceStage`, alternately using the `--use_source_function` flag will utilize the function-based `rabbitmq_source` stage. @@ -64,7 +64,7 @@ morpheus --log_level=INFO --plugin examples/developer_guide/2_2_rabbitmq/rabbitm run pipeline-other \ from-rabbitmq --host=localhost --exchange=logs \ monitor \ - to-file --filename=/tmp/results.json --overwrite + to-file --filename=results.json --overwrite ``` ### Write Pipeline diff --git a/examples/developer_guide/2_2_rabbitmq/read_simple.py b/examples/developer_guide/2_2_rabbitmq/read_simple.py index 5de5569270..eb509b1316 100755 --- a/examples/developer_guide/2_2_rabbitmq/read_simple.py +++ b/examples/developer_guide/2_2_rabbitmq/read_simple.py @@ -53,7 +53,7 @@ def run_pipeline(use_source_function: bool): pipeline.add_stage(MonitorStage(config)) # Write the to the output file - pipeline.add_stage(WriteToFileStage(config, filename='/tmp/results.json', file_type=FileTypes.JSON, overwrite=True)) + pipeline.add_stage(WriteToFileStage(config, filename='results.json', file_type=FileTypes.JSON, overwrite=True)) # Run the pipeline pipeline.run() diff --git a/examples/developer_guide/4_rabbitmq_cpp_stage/README.md b/examples/developer_guide/4_rabbitmq_cpp_stage/README.md index 2e3319b65e..3e3364d22b 100644 --- a/examples/developer_guide/4_rabbitmq_cpp_stage/README.md +++ b/examples/developer_guide/4_rabbitmq_cpp_stage/README.md @@ -55,7 +55,7 @@ In a second terminal from the root of the Morpheus repo execute: python examples/developer_guide/4_rabbitmq_cpp_stage/src/read_simple.py ``` -This will read from a RabbitMQ exchange named 'logs', and write the results to `/tmp/results.json`. +This will read from a RabbitMQ exchange named 'logs', and write the results to `results.json`. If no exchange named 'logs' exists in RabbitMQ it will be created. diff --git a/examples/developer_guide/4_rabbitmq_cpp_stage/src/read_simple.py b/examples/developer_guide/4_rabbitmq_cpp_stage/src/read_simple.py index 1edec18e75..d9db97274d 100755 --- a/examples/developer_guide/4_rabbitmq_cpp_stage/src/read_simple.py +++ b/examples/developer_guide/4_rabbitmq_cpp_stage/src/read_simple.py @@ -55,7 +55,7 @@ def run_pipeline(use_cpp, num_threads): pipeline.add_stage(MonitorStage(config)) # Write the to the output file - pipeline.add_stage(WriteToFileStage(config, filename='/tmp/results.json', file_type=FileTypes.JSON, overwrite=True)) + pipeline.add_stage(WriteToFileStage(config, filename='results.json', file_type=FileTypes.JSON, overwrite=True)) # Run the pipeline pipeline.run()