elasticsearch/_async/client/connector.py [204:322]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
self,
*,
connector_id: str,
error_trace: t.Optional[bool] = None,
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
human: t.Optional[bool] = None,
last_access_control_sync_error: t.Optional[str] = None,
last_access_control_sync_scheduled_at: t.Optional[t.Union[str, t.Any]] = None,
last_access_control_sync_status: t.Optional[
t.Union[
str,
t.Literal[
"canceled",
"canceling",
"completed",
"error",
"in_progress",
"pending",
"suspended",
],
]
] = None,
last_deleted_document_count: t.Optional[int] = None,
last_incremental_sync_scheduled_at: t.Optional[t.Union[str, t.Any]] = None,
last_indexed_document_count: t.Optional[int] = None,
last_seen: t.Optional[t.Union[str, t.Any]] = None,
last_sync_error: t.Optional[str] = None,
last_sync_scheduled_at: t.Optional[t.Union[str, t.Any]] = None,
last_sync_status: t.Optional[
t.Union[
str,
t.Literal[
"canceled",
"canceling",
"completed",
"error",
"in_progress",
"pending",
"suspended",
],
]
] = None,
last_synced: t.Optional[t.Union[str, t.Any]] = None,
pretty: t.Optional[bool] = None,
sync_cursor: t.Optional[t.Any] = None,
body: t.Optional[t.Dict[str, t.Any]] = None,
) -> ObjectApiResponse[t.Any]:
"""
.. raw:: html
Update the connector last sync stats.
Update the fields related to the last sync of a connector.
This action is used for analytics and monitoring.
``_
:param connector_id: The unique identifier of the connector to be updated
:param last_access_control_sync_error:
:param last_access_control_sync_scheduled_at:
:param last_access_control_sync_status:
:param last_deleted_document_count:
:param last_incremental_sync_scheduled_at:
:param last_indexed_document_count:
:param last_seen:
:param last_sync_error:
:param last_sync_scheduled_at:
:param last_sync_status:
:param last_synced:
:param sync_cursor:
"""
if connector_id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'connector_id'")
__path_parts: t.Dict[str, str] = {"connector_id": _quote(connector_id)}
__path = f'/_connector/{__path_parts["connector_id"]}/_last_sync'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
if error_trace is not None:
__query["error_trace"] = error_trace
if filter_path is not None:
__query["filter_path"] = filter_path
if human is not None:
__query["human"] = human
if pretty is not None:
__query["pretty"] = pretty
if not __body:
if last_access_control_sync_error is not None:
__body["last_access_control_sync_error"] = (
last_access_control_sync_error
)
if last_access_control_sync_scheduled_at is not None:
__body["last_access_control_sync_scheduled_at"] = (
last_access_control_sync_scheduled_at
)
if last_access_control_sync_status is not None:
__body["last_access_control_sync_status"] = (
last_access_control_sync_status
)
if last_deleted_document_count is not None:
__body["last_deleted_document_count"] = last_deleted_document_count
if last_incremental_sync_scheduled_at is not None:
__body["last_incremental_sync_scheduled_at"] = (
last_incremental_sync_scheduled_at
)
if last_indexed_document_count is not None:
__body["last_indexed_document_count"] = last_indexed_document_count
if last_seen is not None:
__body["last_seen"] = last_seen
if last_sync_error is not None:
__body["last_sync_error"] = last_sync_error
if last_sync_scheduled_at is not None:
__body["last_sync_scheduled_at"] = last_sync_scheduled_at
if last_sync_status is not None:
__body["last_sync_status"] = last_sync_status
if last_synced is not None:
__body["last_synced"] = last_synced
if sync_cursor is not None:
__body["sync_cursor"] = sync_cursor
__headers = {"accept": "application/json", "content-type": "application/json"}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
elasticsearch/_sync/client/connector.py [204:322]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
self,
*,
connector_id: str,
error_trace: t.Optional[bool] = None,
filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None,
human: t.Optional[bool] = None,
last_access_control_sync_error: t.Optional[str] = None,
last_access_control_sync_scheduled_at: t.Optional[t.Union[str, t.Any]] = None,
last_access_control_sync_status: t.Optional[
t.Union[
str,
t.Literal[
"canceled",
"canceling",
"completed",
"error",
"in_progress",
"pending",
"suspended",
],
]
] = None,
last_deleted_document_count: t.Optional[int] = None,
last_incremental_sync_scheduled_at: t.Optional[t.Union[str, t.Any]] = None,
last_indexed_document_count: t.Optional[int] = None,
last_seen: t.Optional[t.Union[str, t.Any]] = None,
last_sync_error: t.Optional[str] = None,
last_sync_scheduled_at: t.Optional[t.Union[str, t.Any]] = None,
last_sync_status: t.Optional[
t.Union[
str,
t.Literal[
"canceled",
"canceling",
"completed",
"error",
"in_progress",
"pending",
"suspended",
],
]
] = None,
last_synced: t.Optional[t.Union[str, t.Any]] = None,
pretty: t.Optional[bool] = None,
sync_cursor: t.Optional[t.Any] = None,
body: t.Optional[t.Dict[str, t.Any]] = None,
) -> ObjectApiResponse[t.Any]:
"""
.. raw:: html
Update the connector last sync stats.
Update the fields related to the last sync of a connector.
This action is used for analytics and monitoring.
``_
:param connector_id: The unique identifier of the connector to be updated
:param last_access_control_sync_error:
:param last_access_control_sync_scheduled_at:
:param last_access_control_sync_status:
:param last_deleted_document_count:
:param last_incremental_sync_scheduled_at:
:param last_indexed_document_count:
:param last_seen:
:param last_sync_error:
:param last_sync_scheduled_at:
:param last_sync_status:
:param last_synced:
:param sync_cursor:
"""
if connector_id in SKIP_IN_PATH:
raise ValueError("Empty value passed for parameter 'connector_id'")
__path_parts: t.Dict[str, str] = {"connector_id": _quote(connector_id)}
__path = f'/_connector/{__path_parts["connector_id"]}/_last_sync'
__query: t.Dict[str, t.Any] = {}
__body: t.Dict[str, t.Any] = body if body is not None else {}
if error_trace is not None:
__query["error_trace"] = error_trace
if filter_path is not None:
__query["filter_path"] = filter_path
if human is not None:
__query["human"] = human
if pretty is not None:
__query["pretty"] = pretty
if not __body:
if last_access_control_sync_error is not None:
__body["last_access_control_sync_error"] = (
last_access_control_sync_error
)
if last_access_control_sync_scheduled_at is not None:
__body["last_access_control_sync_scheduled_at"] = (
last_access_control_sync_scheduled_at
)
if last_access_control_sync_status is not None:
__body["last_access_control_sync_status"] = (
last_access_control_sync_status
)
if last_deleted_document_count is not None:
__body["last_deleted_document_count"] = last_deleted_document_count
if last_incremental_sync_scheduled_at is not None:
__body["last_incremental_sync_scheduled_at"] = (
last_incremental_sync_scheduled_at
)
if last_indexed_document_count is not None:
__body["last_indexed_document_count"] = last_indexed_document_count
if last_seen is not None:
__body["last_seen"] = last_seen
if last_sync_error is not None:
__body["last_sync_error"] = last_sync_error
if last_sync_scheduled_at is not None:
__body["last_sync_scheduled_at"] = last_sync_scheduled_at
if last_sync_status is not None:
__body["last_sync_status"] = last_sync_status
if last_synced is not None:
__body["last_synced"] = last_synced
if sync_cursor is not None:
__body["sync_cursor"] = sync_cursor
__headers = {"accept": "application/json", "content-type": "application/json"}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -