MessageThreadCursor

toloka.streaming.cursor.MessageThreadCursor | Source code

MessageThreadCursor(
self,
toloka_client: Union[TolokaClient, AsyncTolokaClient],
folder: Union[str, Folder, List[Union[str, Folder]], None] = None,
folder_ne: Union[str, Folder, List[Union[str, Folder]], None] = None,
id_lt: Optional[str] = None,
id_lte: Optional[str] = None,
id_gt: Optional[str] = None,
id_gte: Optional[str] = None,
created_lt: Optional[datetime] = None,
created_lte: Optional[datetime] = None,
created_gt: Optional[datetime] = None,
created_gte: Optional[datetime] = None
)

Iterator over messages by create time.

Parameters Description

ParametersTypeDescription
toloka_clientUnion[TolokaClient, AsyncTolokaClient]

TolokaClient object that is being used to search messages.

requestMessageThreadSearchRequest

Base request to search messages.

Examples:

Iterate over all messages.

it = MessageThreadCursor(toloka_client=toloka_client)
all_messages = list(it)
# ... new messages could appear ...
new_messages = list(it) # Contains only new messages, appeared since the previous call.
Toloka-Kit
OverviewGetting OAuth tokenQuick start
Recipes
Reference
toloka.client
toloka.async_client
toloka.autoquality [autoquality]
toloka.metrics
toloka.streaming