Firebird/Concepts - Revision history

Stonezhong: /* Exception Handling */

2023-09-16T22:46:38Z

Exception Handling

← Older revision		Revision as of 22:46, 16 September 2023
Line 174:		Line 174:
	<div class="mw-collapsible-preview"></div>		<div class="mw-collapsible-preview"></div>
	<div class="mw-collapsible-content">		<div class="mw-collapsible-content">
			* When you register a pipeline, 3 message queue will be created, they are
			* ${pipeline_name}: all the message gets routed here
			* ${pipeline_name}-error: when a message failed to process, it will be posted here, it has following fields: error_count, recent_errors: array of {failed_time, error_message}
			* ${pipeline_critical}-critical: when a message failed too many times, it will be moved here.
	</div>		</div>
	</div>		</div>
	<p></p>		<p></p>

2023-09-16T22:41:44Z

Models

← Older revision		Revision as of 22:41, 16 September 2023
Line 166:		Line 166:
	<div class="mw-collapsible-content">		<div class="mw-collapsible-content">
	Represent a RabbitMQ connection		Represent a RabbitMQ connection
			</div>
			</div>
			<p></p>

			= Exception Handling =
			<div class="toccolours mw-collapsible mw-collapsed expandable">
			<div class="mw-collapsible-preview"></div>
			<div class="mw-collapsible-content">
	</div>		</div>
	</div>		</div>
	<p></p>		<p></p>

2023-09-15T10:22:01Z

Models

← Older revision		Revision as of 10:22, 15 September 2023
Line 110:		Line 110:
	type: Either PortType.INPUT or PortType.OUTPUT, represent it is a input port or output port		type: Either PortType.INPUT or PortType.OUTPUT, represent it is a input port or output port
	id: ID of the port, it is unique within the node		id: ID of the port, it is unique within the node
	~~owner~~: The node which this port belongs to		node: The node which this port belongs to
	</nowiki></pre>		</nowiki></pre>

Line 142:		Line 142:
	description: Detailed description of this pipeline.		description: Detailed description of this pipeline.
	mq: RabbitMQ instance		mq: RabbitMQ instance
	nodes: ~~Tuple containing~~ all node belongs to this pipeline.		nodes: Containing all node belongs to this pipeline.
	</nowiki></pre>		</nowiki></pre>

2023-09-15T10:17:02Z

Overview

← Older revision		Revision as of 10:17, 15 September 2023
Line 17:		Line 17:
	<div class="mw-collapsible-preview">wiring</div>		<div class="mw-collapsible-preview">wiring</div>
	<div class="mw-collapsible-content">		<div class="mw-collapsible-content">
	You can connect an output port to one ~~ore~~ more input port to ~~set~~ the data ~~flow direction~~.		* You can connect an output port to one or more input ports.
			* When you emit data via an output port, the data gets sends to all the input port that is connected, and the node owns those input will receive the data.
	</div>		</div>
	</div>		</div>

2023-05-13T05:33:24Z

Models

← Older revision		Revision as of 05:33, 13 May 2023
Line 52:		Line 52:
	<b>method: on_message</b>		<b>method: on_message</b>
	<pre><nowiki>		<pre><nowiki>
	on_message(self, ~~port_name~~:str, data:Any)		on_message(self, port_id:str, data:Any)

	Called when this node receives data. ~~port_name~~ is the ~~name~~ of the port which receive the data, data is the JSON payload of the data.		Called when this node receives data. port_id is the id of the port which receive the data, data is the JSON payload of the data.
	</nowiki></pre>		</nowiki></pre>

2023-05-13T04:53:15Z

Pipeline

← Older revision		Revision as of 04:53, 13 May 2023
Line 128:		Line 128:
	<p></p>		<p></p>

	~~== Pipeline ==~~
	<div class="toccolours mw-collapsible mw-collapsed expandable">		<div class="toccolours mw-collapsible mw-collapsed expandable">
	<div class="mw-collapsible-preview">Pipeline</div>		<div class="mw-collapsible-preview">Pipeline</div>
Line 165:		Line 164:
	<div class="mw-collapsible-preview">RabbitMQ</div>		<div class="mw-collapsible-preview">RabbitMQ</div>
	<div class="mw-collapsible-content">		<div class="mw-collapsible-content">
			Represent a RabbitMQ connection
	</div>		</div>
	</div>		</div>
	<p></p>		<p></p>

2023-05-13T04:52:07Z

Models

← Older revision		Revision as of 04:52, 13 May 2023
Line 152:		Line 152:
	</nowiki></pre>		</nowiki></pre>

			<b>method: <nowiki>[]</nowiki></b>
	<pre><nowiki>		<pre><nowiki>
	~~def add_node(self, name:str, node_class, argc, *kwargs)~~		# You can use [] to get node by id
			pipeline["foo"] # get node with id "foo" of this pipeline
	# ~~add a~~ node ~~to the~~ pipeline~~, argc, and *kwargs will be passed to the constructor~~
	~~</nowiki></pre>~~

	~~<pre><nowiki>~~
	~~def connect(self, *, src_node_name, src_port_name=DEFAULT_PORT_NAME, dst_node_name, dst_port_name=DEFAULT_PORT_NAME)~~

	# ~~connect one~~ node~~'s output port to another node's input port~~
	</nowiki></pre>		</nowiki></pre>

2023-05-13T04:48:11Z

Pipeline

← Older revision		Revision as of 04:48, 13 May 2023
Line 138:		Line 138:
	<b>Properties</b>		<b>Properties</b>
	<pre><nowiki>		<pre><nowiki>
	* id: The id of the pipeline, every pipeline has a unique id.		id: The id of the pipeline, every pipeline has a unique id.
	* title: A human readable short description of this pipeline.		title: A human readable short description of this pipeline.
	* description: Detailed description of this pipeline.		description: Detailed description of this pipeline.
	* mq: RabbitMQ instance		mq: RabbitMQ instance
	* nodes: Tuple containing all node belongs to this pipeline.		nodes: Tuple containing all node belongs to this pipeline.
	</nowiki></pre>		</nowiki></pre>

	~~Methods~~:		<b>method: message_loop</b>
	<pre><nowiki>		<pre><nowiki>
	def message_loop(self):		def message_loop(self):

2023-05-13T04:47:30Z

Pipeline

← Older revision		Revision as of 04:47, 13 May 2023
Line 136:		Line 136:
	* A node's output port can connect to another node's input port		* A node's output port can connect to another node's input port

	Properties:		<b>Properties</b>
	* mq: ~~message queue~~		<pre><nowiki>
	* ~~node_dict~~: ~~dictionary, key is node name, value is~~ node		* id: The id of the pipeline, every pipeline has a unique id.
			* title: A human readable short description of this pipeline.
			* description: Detailed description of this pipeline.
			* mq: RabbitMQ instance
			* nodes: Tuple containing all node belongs to this pipeline.
			</nowiki></pre>

	Methods:		Methods:

2023-05-13T04:42:52Z

Port

← Older revision		Revision as of 04:42, 13 May 2023
Line 100:		Line 100:
	<p></p>		<p></p>

	~~== Port ==~~
	<div class="toccolours mw-collapsible mw-collapsed expandable">		<div class="toccolours mw-collapsible mw-collapsed expandable">
	<div class="mw-collapsible-preview">Port</div>		<div class="mw-collapsible-preview">Port</div>
Line 122:		Line 121:
	<pre><nowiki>		<pre><nowiki>
	def emit(self, json_data:Any)		def emit(self, json_data:Any)

	# emit JSON data to this port		# emit JSON data to this port
	</nowiki></pre>		</nowiki></pre>
Line 130:		Line 128:
	<p></p>		<p></p>

			== Pipeline ==
	<div class="toccolours mw-collapsible mw-collapsed expandable">		<div class="toccolours mw-collapsible mw-collapsed expandable">
	<div class="mw-collapsible-preview">Pipeline</div>		<div class="mw-collapsible-preview">Pipeline</div>