Messageยถ
- class Message(content: RecordDict, dst_node_id: int, message_type: str, *, ttl: float | None = None, group_id: str | None = None)[์์ค]ยถ
- class Message(content: RecordDict, *, reply_to: Message, ttl: float | None = None)
- class Message(error: Error, *, reply_to: Message, ttl: float | None = None)
๊ธฐ๋ฐ ํด๋์ค:
object
Represents a message exchanged between ClientApp and ServerApp.
This class encapsulates the payload and metadata necessary for communication between a ClientApp and a ServerApp.
- ๋งค๊ฐ๋ณ์:
content (Optional[RecordDict] (default: None)) โ ๋ค๋ฅธ ์ํฐํฐ(์: ์๋ฒ ์ธก ๋ก์ง์ด ํด๋ผ์ด์ธํธ๋ก ์ ์กํ๊ฑฐ๋ ๊ทธ ๋ฐ๋๋ก ์ ์กํ๋ ๋ฑ)๊ฐ ์ ์กํ๊ฑฐ๋ ์ ์กํ ๋ ์ฝ๋๋ฅผ ๋ณด์ ํฉ๋๋ค.
error (Optional[Error] (default: None)) โ ๋ค๋ฅธ ๋ฉ์์ง๋ฅผ ์ฒ๋ฆฌํ ๋ ๋ฐ์ํ ์ค๋ฅ์ ๋ํ ์ ๋ณด๋ฅผ ์บก์ฒํ๋ ๋ฐ์ดํฐ ํด๋์ค์ ๋๋ค.
dst_node_id (Optional[int] (default: None)) โ ์ด ๋ฉ์์ง๋ฅผ ์์ ํ๋ ๋ ธ๋์ ์๋ณ์์ ๋๋ค.
message_type (Optional[str] (default: None)) โ ์์ ์ธก์์ ์คํํ ์์ ์ ์ธ์ฝ๋ฉํ๋ ๋ฌธ์์ด์ ๋๋ค.
ttl (Optional[float] (default: None)) โ Time-to-live (TTL) for this message in seconds. If None (default), the TTL is set to 43,200 seconds (12 hours).
group_id (Optional[str] (default: None)) โ ๋ฉ์์ง๋ฅผ ๊ทธ๋ฃนํํ๊ธฐ ์ํ ์๋ณ์์ ๋๋ค. ์ผ๋ถ ์ค์ ์์๋ FL ๋ผ์ด๋๋ก ์ฌ์ฉ๋ฉ๋๋ค.
reply_to (Optional[Message] (default: None)) โ The instruction message to which this message is a reply. This message does not retain the original messageโs content but derives its metadata from it.
๋ฉ์๋
create_error_reply
(error[, ttl])์ค๋ฅ๊ฐ ๋ฐ์ํ์์ ๋ํ๋ด๋ ๋ต์ฅ ๋ฉ์์ง๋ฅผ ์์ฑํฉ๋๋ค.
create_reply
(content[, ttl])์ง์ ๋ ์ฝํ ์ธ ์ TTL์ ์ฌ์ฉํ์ฌ ์ด ๋ฉ์์ง์ ๋ํ ๋ต๊ธ์ ์์ฑํฉ๋๋ค.
๋ฉ์์ง์ ์ฝํ ์ธ ๊ฐ ์์ผ๋ฉด True์ ๋ฐํํ๊ณ , ๊ทธ๋ ์ง ์์ผ๋ฉด False์ ๋ฐํํฉ๋๋ค.
๋ฉ์์ง์ ์ค๋ฅ๊ฐ ์์ผ๋ฉด True์ ๋ฐํํ๊ณ , ๊ทธ๋ ์ง ์์ผ๋ฉด False์ ๋ฐํํฉ๋๋ค.
์์ฑ
์ด ๋ฉ์์ง์ ๋ด์ฉ์ ๋๋ค.
์ด ๋ฉ์์ง๊ฐ ์บก์ฒํ ์ค๋ฅ์ ๋๋ค.
์คํํ ๋ฉ์์ง์ ๋ํ ์ ๋ณด๋ฅผ ํฌํจํ ๋ฐ์ดํฐ ํด๋์ค์ ๋๋ค.
- property content: RecordDictยถ
์ด ๋ฉ์์ง์ ๋ด์ฉ์ ๋๋ค.
- create_error_reply(error: Error, ttl: float | None = None) Message [์์ค]ยถ
์ค๋ฅ๊ฐ ๋ฐ์ํ์์ ๋ํ๋ด๋ ๋ต์ฅ ๋ฉ์์ง๋ฅผ ์์ฑํฉ๋๋ค.
- ๋งค๊ฐ๋ณ์:
error (Error) โ ์ค๋ฅ๊ฐ ๋ฐ์ํ์ต๋๋ค.
ttl (Optional[float] (default: None)) โ ์ด ๋ฉ์์ง์ ๋จ์ ์๊ฐ(์ด)์ ๋๋ค. ์ค์ ํ์ง ์์ผ๋ฉด ์์ ๋ ๋ฉ์์ง๊ฐ ๋ง๋ฃ๋๊ธฐ ์ ๊น์ง ๋จ์ ์๊ฐ์ ๊ธฐ์ค์ผ๋ก ์ค์ ๋ฉ๋๋ค. ์ด๋ ๋ค์๊ณผ ๊ฐ์ ๊ณต์์ ๋ฐ๋ฆ ๋๋ค: ttl = msg.meta.ttl - (reply.meta.created_at - msg.meta.created_at)
- ๋ฐํ:
message โ A Message containing only the relevant error and metadata.
- ๋ฐํ ํ์:
- create_reply(content: RecordDict, ttl: float | None = None) Message [์์ค]ยถ
์ง์ ๋ ์ฝํ ์ธ ์ TTL์ ์ฌ์ฉํ์ฌ ์ด ๋ฉ์์ง์ ๋ํ ๋ต๊ธ์ ์์ฑํฉ๋๋ค.
The method generates a new Message as a reply to this message. It inherits โrun_idโ, โsrc_node_idโ, โdst_node_idโ, and โmessage_typeโ from this message and sets โreply_to_message_idโ to the ID of this message.
- ๋งค๊ฐ๋ณ์:
content (RecordDict) โ ๋ต์ฅ ๋ฉ์์ง์ ์ฝํ ์ธ ์ ๋๋ค.
ttl (Optional[float] (default: None)) โ ์ด ๋ฉ์์ง์ ๋จ์ ์๊ฐ(์ด)์ ๋๋ค. ์ค์ ํ์ง ์์ผ๋ฉด ์์ ๋ ๋ฉ์์ง๊ฐ ๋ง๋ฃ๋๊ธฐ ์ ๊น์ง ๋จ์ ์๊ฐ์ ๊ธฐ์ค์ผ๋ก ์ค์ ๋ฉ๋๋ค. ์ด๋ ๋ค์๊ณผ ๊ฐ์ ๊ณต์์ ๋ฐ๋ฆ ๋๋ค: ttl = msg.meta.ttl - (reply.meta.created_at - msg.meta.created_at)
- ๋ฐํ:
๋ต์ฅ์ ๋ํ๋ด๋ ์๋ก์ด ๋ฉ์์ง ์ธ์คํด์ค์ ๋๋ค.
- ๋ฐํ ํ์:
- has_content() bool [์์ค]ยถ
๋ฉ์์ง์ ์ฝํ ์ธ ๊ฐ ์์ผ๋ฉด True์ ๋ฐํํ๊ณ , ๊ทธ๋ ์ง ์์ผ๋ฉด False์ ๋ฐํํฉ๋๋ค.