Adapter extension for inbound messages from robotic automation platforms to unified automation platform
Implementations directed to direct messaging between one or more robotic process automation (RPA) platforms, and an autonomic platform (AP), and include actions of receiving, by a platform-specific adapter of the AP, data from a RPA platform of a plurality of RPA platforms the AP interacts with, the data indicating occurrence of a scenario, providing, by an application programming interface (API) of the platform-specific adapter, an occurrence message responsive to the occurrence of the scenario, transmitting, by the API, the message to the AP through a first channel, and transmitting, by the platform-specific adapter, a set of messages to the AP through a second channel that is separate from the first channel, the set of messages communicating tagged data records.
1. A computer-implemented method for direct messaging between one or more robotic process automation (RPA) platforms, and an autonomic platform (AP), the method comprising:
receiving, by a platform-specific adapter of the AP, data from a RPA platform of a plurality of RPA platforms the AP interacts with, the data indicating occurrence of a scenario;
providing, by an application programming interface (API) of the platform-specific adapter, an occurrence message responsive to the occurrence of the scenario;
transmitting, by the API, the message to the AP through a first channel; and
transmitting, by the platform-specific adapter, a set of messages to the AP through a second channel that is separate from the first channel, the set of messages communicating tagged data records.
2. The method of claim 1 , wherein the first channel enables communication between the API and a data pipeline of the AP, and the second channel enables communication between a platform data module of the platform-specific adapter, and the data pipeline.
3. The method of claim 1 , wherein the API comprises a controller that communicates with the AP through the first channel.
4. The method of claim 1 , wherein the data from the RPA platform is provided in response to the occurrence, and is independent of data that the set of messages is provided from.
5. The method of claim 1 , wherein the occurrence comprises expiration of credentials that the RPA platform requires to perform one or more tasks.
6. The method of claim 1 , wherein the set of messages is provided by:
providing and from a set of data records received from the RPA platform, a first set of data records comprising tagged data records, and a second set of data records comprising untagged data records;
for each data record in the second set of data records, providing a data change tuple comprising an identifier, and a hash value;
providing a sub-set of data records from the second set of data records based on comparing one or more hash values of data change tuples to a set of stored hash values, the sub-set of data records comprising fewer data records than the second set of data records, and each data record in the sub-set of data records comprising a change indicator; and
determining a tag for each data record in the sub-set of data records based on a respective change indicator.
7. The method of claim 1 , wherein the platform-specific adaptor is specific to the RPA platform, and the AP communicates with multiple RPA platforms.
8. The method of claim 1 , wherein a unified automation platform (UAP) comprises the AP.
9. One or more non-transitory computer-readable storage media coupled to one or more processors and having instructions stored thereon which, when executed by the one or more processors, cause the one or more processors to perform operations for direct messaging between one or more robotic process automation (RPA) platforms, and an autonomic platform (AP), the operations comprising:
receiving, by a platform-specific adapter of the AP, data from a RPA platform of a plurality of RPA platforms the AP interacts with, the data indicating occurrence of a scenario;
providing, by an application programming interface (API) of the platform-specific adapter, an occurrence message responsive to the occurrence of the scenario;
transmitting, by the API, the message to the AP through a first channel; and
transmitting, by the platform-specific adapter, a set of messages to the AP through a second channel that is separate from the first channel, the set of messages communicating tagged data records.
10. The non-transitory computer-readable storage media of claim 9 , wherein the first channel enables communication between the API and a data pipeline of the AP, and the second channel enables communication between a platform data module of the platform-specific adapter, and the data pipeline.
11. The non-transitory computer-readable storage media of claim 9 , wherein the API comprises a controller that communicates with the AP through the first channel.
12. The non-transitory computer-readable storage media of claim 9 , wherein the data from the RPA platform is provided in response to the occurrence, and is independent of data that the set of messages is provided from.
13. The non-transitory computer-readable storage media of claim 9 , wherein the occurrence comprises expiration of credentials that the RPA platform requires to perform one or more tasks.
14. The non-transitory computer-readable storage media of claim 9 , wherein the set of messages is provided by:
providing and from a set of data records received from the RPA platform, a first set of data records comprising tagged data records, and a second set of data records comprising untagged data records;
for each data record in the second set of data records, providing a data change tuple comprising an identifier, and a hash value;
providing a sub-set of data records from the second set of data records based on comparing one or more hash values of data change tuples to a set of stored hash values, the sub-set of data records comprising fewer data records than the second set of data records, and each data record in the sub-set of data records comprising a change indicator; and
determining a tag for each data record in the sub-set of data records based on a respective change indicator.
15. The non-transitory computer-readable storage media of claim 9 , wherein the platform-specific adaptor is specific to the RPA platform, and the AP communicates with multiple RPA platforms.
16. The non-transitory computer-readable storage media of claim 9 , wherein a unified automation platform (UAP) comprises the AP.
17. A system, comprising:
one or more processors; and
a computer-readable storage device coupled to the one or more processors and having instructions stored thereon which, when executed by the one or more processors, cause the one or more processors to perform operations for direct messaging between one or more robotic process automation (RPA) platforms, and an autonomic platform (AP), the operations comprising:
receiving, by a platform-specific adapter of the AP, data from a RPA platform of a plurality of RPA platforms the AP interacts with, the data indicating occurrence of a scenario;
providing, by an application programming interface (API) of the platform-specific adapter, an occurrence message responsive to the occurrence of the scenario;
transmitting, by the API, the message to the AP through a first channel; and
transmitting, by the platform-specific adapter, a set of messages to the AP through a second channel that is separate from the first channel, the set of messages communicating tagged data records.
18. The system of claim 17 , wherein the first channel enables communication between the API and a data pipeline of the AP, and the second channel enables communication between a platform data module of the platform-specific adapter, and the data pipeline.
19. The system of claim 17 , wherein the API comprises a controller that communicates with the AP through the first channel.
20. The system of claim 17 , wherein the data from the RPA platform is provided in response to the occurrence, and is independent of data that the set of messages is provided from.
21. The system of claim 17 , wherein the occurrence comprises expiration of credentials that the RPA platform requires to perform one or more tasks.
22. The system of claim 17 , wherein the set of messages is provided by:
providing and from a set of data records received from the RPA platform, a first set of data records comprising tagged data records, and a second set of data records comprising untagged data records;
for each data record in the second set of data records, providing a data change tuple comprising an identifier, and a hash value;
providing a sub-set of data records from the second set of data records based on comparing one or more hash values of data change tuples to a set of stored hash values, the sub-set of data records comprising fewer data records than the second set of data records, and each data record in the sub-set of data records comprising a change indicator; and
determining a tag for each data record in the sub-set of data records based on a respective change indicator.
23. The system of claim 17 , wherein the platform-specific adaptor is specific to the RPA platform, and the AP communicates with multiple RPA platforms.
24. The system of claim 17 , wherein a unified automation platform (UAP) comprises the AP.