Updating old examples (1/2)

examples/ack_test.yaml

@@ -1,6 +1,13 @@
 ---
 # Simple loopback flow
 # Solace -> Pass Through -> Solace
+# 
+# required ENV variables:
+# - SOLACE_BROKER_URL
+# - SOLACE_BROKER_USERNAME
+# - SOLACE_BROKER_PASSWORD
+# - SOLACE_BROKER_VPN
+
 log:
   stdout_log_level: DEBUG
   log_file_level: DEBUG

examples/anthropic_bedrock.yaml

@@ -4,6 +4,22 @@
 # sends the response back to the Solace broker
 # It will ask the model to write a dry joke about the input
 # message. It takes the entire payload of the input message
+# 
+# Dependencies:
+# pip install langchain_aws langchain_community
+# 
+# Dependencies:
+# - langchain_aws
+# pip install langchain_aws
+# 
+# required ENV variables:
+# - SOLACE_BROKER_URL
+# - SOLACE_BROKER_USERNAME
+# - SOLACE_BROKER_PASSWORD
+# - SOLACE_BROKER_VPN
+# - AWS_BEDROCK_ANTHROPIC_CLAUDE_MODEL_ID
+
+
 instance_name: LLM
 log:
   stdout_log_level: DEBUG

examples/chat_model_with_history.yaml

@@ -1,5 +1,12 @@
 ---
-# Example uses goes from STDIN to STDOUT with a chat model with history
+# Example uses goes from STDIN to STDOUT with a chat model with history hosted on AWS Bedrock
+
+# Dependencies:
+# pip install langchain_aws
+
+# required ENV variables:
+# - AWS_DEFAULT_REGION
+
 log:
   stdout_log_level: INFO
   log_file_level: DEBUG

examples/error_handler.yaml

@@ -1,8 +1,21 @@
 ---
 # This is an example configuration file that contains an 
 # error handler flow and a test flow. The error handler flow
-# will log any error messages locally and will also
-# send them to a Solace broker. 
+# will log any error messages locally to a file and will also
+# send them to a Solace broker.
+#
+# It will subscribe to `my/topic1` and expect an event with the payload:
+# {
+#   "value": <number>
+# }
+# If value is not a number, the error will be caught, logged to file and send back to the Solace broker.
+# 
+# required ENV variables:
+# - SOLACE_BROKER_URL
+# - SOLACE_BROKER_USERNAME
+# - SOLACE_BROKER_PASSWORD
+# - SOLACE_BROKER_VPN
+
 instance:
   name: solace_ai_connector1
 log:
@@ -27,12 +40,19 @@ flows:
         component_module: error_input
         component_config:
       - component_name: error_logger
-        component_module: logger
-        component_config:
-          log_level: ERROR
-          max_log_line_size: 1000
+        component_module: file_output
+        input_transforms:
+          - type: copy
+            source_expression: input.payload
+            dest_expression: user_data.log:content
+          - type: copy
+            source_value: a
+            dest_expression: user_data.log:mode
+          - type: copy
+            source_value: error_log.log
+            dest_expression: user_data.log:file_path
         component_input:
-          source_expression: input.payload
+          source_expression: user_data.log
       - component_name: solace_sw_broker
         component_module: broker_output
         component_config: 
@@ -66,7 +86,7 @@ flows:
             - topic: my/topic1
               qos: 1
           payload_encoding: utf-8
-          payload_format: text
+          payload_format: json
 
       - component_name: pass_through
         component_module: pass_through
@@ -89,6 +109,16 @@ flows:
           - type: copy
             source_expression: input.payload
             dest_expression: user_data.output:payload.original_payload
+          - type: copy
+            source_expression: 
+              invoke:
+                module: invoke_functions
+                function: power
+                params:
+                  positional:
+                    - source_expression(input.payload:value) # This will throw an error if value is not a number
+                    - 2
+            dest_expression: user_data.output:payload.valueSquared
           - type: copy
             source_expression: input.user_properties
             dest_expression: user_data.output:payload.user_properties

examples/request_reply.yaml

@@ -2,6 +2,13 @@
 # Example for a request-reply flow
 # Flow 1: stdin -> broker_request_reply -> stdout
 # Flow 2: broker_input -> pass_through -> broker_output
+# 
+# required ENV variables:
+# - SOLACE_BROKER_URL
+# - SOLACE_BROKER_USERNAME
+# - SOLACE_BROKER_PASSWORD
+# - SOLACE_BROKER_VPN
+
 log:
   stdout_log_level: INFO
   log_file_level: INFO