[salesforce] Implement apex data stream for Salesforce

packages/salesforce/changelog.yml

@@ -1,5 +1,10 @@
 # newer versions go on top
 
+- version: 0.3.0
+ changes:
+ - description: Salesforce integration package with "apex" data stream.
+ link: https://github.com/elastic/integrations/pull/4410
+ type: enhancement
 - version: 0.2.1
  changes:
  - description: Add pagination support for "login_rest" and "logout_rest".

packages/salesforce/data_stream/apex/_dev/test/pipeline/test-apex.log

@@ -0,0 +1,6 @@
+{"CALLOUT_TIME":"0","CLIENT_IP":"81.2.69.142","CPU_TIME":"174","DB_TOTAL_TIME":"12","ENTRY_POINT":"Salesforce Migration","EVENT_TYPE":"ApexExecution","EXEC_TIME":"25","IS_LONG_RUNNING_REQUEST":"0","LOGIN_KEY":"QfNecrLXSII6fsBq","NUMBER_SOQL_QUERIES":"1","ORGANIZATION_ID":"00D5j000000VI3n","QUIDDITY":"QTXF","REQUEST_ID":"4lc-XEdmLH121-l1cJ0001","RUN_TIME":"291","SESSION_KEY":"d7DEqANa7nNZZVD","TIMESTAMP":"20230101170000.885","TIMESTAMP_DERIVED":"2023-01-01T17:00:00.885Z","URI":"/home/home.jsp","URI_ID_DERIVED":"AQB00530000009M943","USER_ID":"0055j000000u123","USER_ID_DERIVED":"0055j000000utlP001"}
+{"CLIENT_IP":"81.2.69.142","CPU_TIME":"10","EVENT_TYPE":"ApexCallout","LOGIN_KEY":"QfNecrLXSII6fsBq","METHOD":"GET","ORGANIZATION_ID":"00D5j000000XY0P","REQUEST_ID":"00D5j00XYZBDS","REQUEST_SIZE":"10","RESPONSE_SIZE":"61","RUN_TIME":"237","SESSION_KEY":"DDKHdl+8yn/LIXzz","SUCCESS":"1","TIME":"227","TIMESTAMP":"20230101055317.461","TIMESTAMP_DERIVED":"2023-01-01T05:53:17.461Z","TYPE":"OData","URI":"CALLOUT-LOG","URI_ID_DERIVED":"AQB00530000009M943","URL":"https://temp.website.here.sh/odata/Random","USER_ID":"0055j000000PQ01","USER_ID_DERIVED":"0055j000000utll12"}
+{"ACTION":"query","ENTITY":"HealthcareBlog","EVENT_TYPE":"ExternalCustomApexCallout","EXECUTE_MS":"2","FETCH_MS":"191","FILTER":"Filter:[columnName=CustomerID, columnValue=537, subfilters=null, tableName=Order, type=EQUALS]","LIMIT":"51","MESSAGE":"System.UnexpectedException: Query is either selecting too many fields or the filter conditions are too complicated","OFFSET":"0","ORDERBY":"(Order:[columnName=DisplayUrl, direction=ASCENDING, tableName=HealthcareBlog], Order:[columnName=ExternalId, direction=ASCENDING, tableName=HealthcareBlog], Order:[columnName=ExternalId, direction=...","ORGANIZATION_ID":"00D5j000000VI3n","REQUEST_ID":"TID:85776000006973d59e","ROWS":"-1","ROWS_FETCHED":"51","SELECT":"(ColumnSelection:[aggregation=NONE, columnName=ExternalId, tableName=HealthcareBlog], ColumnSelection:[aggregation=NONE, columnName=DisplayUrl, tableName=HealthcareBlog], ColumnSelection:[aggregati...","STATUS":"1","SUBQUERIES":"SubQueries","THROUGHPUT":"264.2487","TIMESTAMP":"20230101114253.447","TIMESTAMP_DERIVED":"2023-01-01T11:42:53.447Z","TOTAL_MS":"193","USER_ID":"0055j000000utlP"}
+{ "EVENT_TYPE": "ApexSoap", "TIMESTAMP": "20230104064436.203", "REQUEST_ID": "4nR74Q97128rIbdV2ampDi-", "ORGANIZATION_ID": "00D2wpq000GmWPH", "USER_ID": "0052wpq000ACf2Q", "RUN_TIME": "322", "CPU_TIME": "228", "URI": "APEXSOAP", "SESSION_KEY": "DDKHdl+8yn/LIXzz", "LOGIN_KEY": "Zl16H9F+juAl99mI", "USER_TYPE": "Standard", "REQUEST_STATUS": "S", "DB_TOTAL_TIME": "81604961", "CLIENT_NAME": "CallOptions", "CLASS_NAME": "ContactResource", "METHOD_NAME": "getContactIdAndNames", "LIMIT_USAGE_PERCENT": "1.19", "QUERY": "Query", "TIMESTAMP_DERIVED": "2023-01-04T06:44:36.203Z", "USER_ID_DERIVED": "0052w00000ACf2QAAT", "CLIENT_IP": "81.2.69.142", "URI_ID_DERIVED": "DDKHdl+8yn/LIXzz" }
+{ "EVENT_TYPE": "ApexTrigger", "TIMESTAMP": "20230101101141.419", "REQUEST_ID": "4mbVQZtZj3QuSFl1cIPeV-", "ORGANIZATION_ID": "00D5j000000VI3n", "USER_ID": "0055j000000utlP", "RUN_TIME": "320", "CPU_TIME": "5", "URI": "/showAccounts/", "SESSION_KEY": "SYWCKuVRFIoMOBSJ", "LOGIN_KEY": "UOyL83hAn7WpjB7T", "USER_TYPE": "Standard", "REQUEST_STATUS": "f", "DB_TOTAL_TIME": "39254335", "TRIGGER_ID": "01q5j000000ClvF", "TRIGGER_NAME": "HelloWorldTrigger", "ENTITY_NAME": "Book__c", "TRIGGER_TYPE": "BeforeInsert", "EXEC_TIME": "8", "TIMESTAMP_DERIVED": "2023-01-01T10:11:41.419Z", "USER_ID_DERIVED": "0055j000000utlPAAQ", "CLIENT_IP": "81.2.69.142", "URI_ID_DERIVED": "0052w00000ACf2QAAT" }
+{ "EVENT_TYPE": "ApexRestApi", "TIMESTAMP": "20230101062453.951", "REQUEST_ID": "4mbJ2VQY2Jbggkl1cJIIe-", "ORGANIZATION_ID": "00D5j000000VI3n", "USER_ID": "0055j000000utlP", "RUN_TIME": "320", "CPU_TIME": "206", "URI": "/showAccounts/", "SESSION_KEY": "SYWCKuVRFIoMOBSJ", "LOGIN_KEY": "UOyL83hAn7WpjB7T", "USER_TYPE": "Standard", "REQUEST_STATUS": "F", "DB_TOTAL_TIME": "39254335", "METHOD": "GET", "MEDIA_TYPE": "application/json;charset=UTF-8", "STATUS_CODE": "500", "USER_AGENT": "9999", "ROWS_PROCESSED": "0", "NUMBER_FIELDS": "2", "DB_BLOCKS": "832", "DB_CPU_TIME": "20", "REQUEST_SIZE": "57", "RESPONSE_SIZE": "234", "ENTITY_NAME": "Book__c", "TIMESTAMP_DERIVED": "2023-01-01T06:24:53.951Z", "USER_ID_DERIVED": "0055j000000utlPAAQ", "CLIENT_IP": "81.2.69.142", "URI_ID_DERIVED": "0052w00000ACf2QAAT" }