Nguyen Dao (Bach)
10/28/2023, 1:14 PMkapa.ai
10/28/2023, 1:15 PM<https://api.airbyte.com/v1/jobs/{jobId}> Replace {jobId} with the actual ID of the job you want to monitor. Here is a sample code snippet on how to use this endpoint: csharp //Checks every 10 seconds the status of the job while(jobStatus == "running") { //Gets status of the job client = new RestClient("<https://api.airbyte.com/v1/jobs/>" + jobId);//We add the jobId request = new RestRequest(); request.AddHeader("accept", "application/json"); request.AddHeader("content-type", "application/json"); request.AddHeader("Authorization", "Bearer {YourApiKey}"); dynamic statusResponse = client.ExecuteGet(request); //Deserialize response to get the status of the job apiResponse = JsonConvert.DeserializeObject(statusResponse.Content); jobStatus = apiResponse.status; //Waits 10 seconds.. Thread.Sleep(10000); //Prints info in console depending on the status if (jobStatus == "running") { Console.WriteLine("Job running..."); } else { Console.WriteLine("Job Finished..."); Console.WriteLine(" "); Console.WriteLine("Sync details:"); Console.WriteLine(" JobId:" + apiResponse.jobId); Console.WriteLine(" Status:" + jobStatus); Console.WriteLine(" Rows/Bytes Synced:" + apiResponse.rowsSynced + "/" + apiResponse.bytesSynced); Console.WriteLine(" Sync Start Time:" + apiResponse.startTime); Console.WriteLine(" Sync Last Updated:" + apiResponse.lastUpdatedAt); Console.WriteLine(" Sync Duration:" + apiResponse.duration); } } Please note that you need to replace {YourApiKey} with your actual API key. This information is extracted from the [Airbyte tutorial on creating and monitoring a data pipeline using the Airbyte API](https://airbyte.com/tutorials/create-and-monitor-a-data-pipeline-using-the-airbyte-api).Nguyen Dao (Bach)
10/28/2023, 1:16 PMkapa.ai
10/28/2023, 1:16 PMkapa.ai
10/28/2023, 1:17 PM<http://localhost:8000/api/v1/jobs/{{jobId}}> Replace {{jobId}} with the actual ID of the job you want to monitor. Please note that the above URL assumes that your Airbyte instance is running on the default port 8000. If you have configured it to run on a different port, please adjust the URL accordingly. Here is a sample code snippet on how to use this endpoint: csharp //Checks every 10 seconds the status of the job while(jobStatus == "running") { //Gets status of the job client = new RestClient("<http://localhost:8000/api/v1/jobs/>" + jobId);//We add the jobId request = new RestRequest(); request.AddHeader("accept", "application/json"); request.AddHeader("content-type", "application/json"); request.AddHeader("Authorization", "Bearer {YourApiKey}"); dynamic statusResponse = client.ExecuteGet(request); //Deserialize response to get the status of the job apiResponse = JsonConvert.DeserializeObject(statusResponse.Content); jobStatus = apiResponse.status; //Waits 10 seconds.. Thread.Sleep(10000); //Prints info in console depending on the status if (jobStatus == "running") { Console.WriteLine("Job running..."); } else { Console.WriteLine("Job Finished..."); Console.WriteLine(" "); Console.WriteLine("Sync details:"); Console.WriteLine(" JobId:" + apiResponse.jobId); Console.WriteLine(" Status:" + jobStatus); Console.WriteLine(" Rows/Bytes Synced:" + apiResponse.rowsSynced + "/" + apiResponse.bytesSynced); Console.WriteLine(" Sync Start Time:" + apiResponse.startTime); Console.WriteLine(" Sync Last Updated:" + apiResponse.lastUpdatedAt); Console.WriteLine(" Sync Duration:" + apiResponse.duration); } } Please note that you need to replace {YourApiKey} with your actual API key. This information is extracted from the [Airbyte tutorial on creating and monitoring a data pipeline using the Airbyte API](https://airbyte.com/tutorials/create-and-monitor-a-data-pipeline-using-the-airbyte-api).Nguyen Dao (Bach)
10/28/2023, 2:18 PMkapa.ai
10/28/2023, 2:18 PMkapa.ai
10/28/2023, 2:19 PMhttp://<your-public-ip>:8000/api/v1/jobs/{{jobId}} Replace <your-public-ip> with the actual public IP address of your server and {{jobId}} with the actual ID of the job you want to monitor. Here is a sample code snippet on how to use this endpoint: csharp //Checks every 10 seconds the status of the job while(jobStatus == "running") { //Gets status of the job client = new RestClient("http://<your-public-ip>:8000/api/v1/jobs/" + jobId);//We add the jobId request = new RestRequest(); request.AddHeader("accept", "application/json"); request.AddHeader("content-type", "application/json"); request.AddHeader("Authorization", "Bearer {YourApiKey}"); dynamic statusResponse = client.ExecuteGet(request); //Deserialize response to get the status of the job apiResponse = JsonConvert.DeserializeObject(statusResponse.Content); jobStatus = apiResponse.status; //Waits 10 seconds.. Thread.Sleep(10000); //Prints info in console depending on the status if (jobStatus == "running") { Console.WriteLine("Job running..."); } else { Console.WriteLine("Job Finished..."); Console.WriteLine(" "); Console.WriteLine("Sync details:"); Console.WriteLine(" JobId:" + apiResponse.jobId); Console.WriteLine(" Status:" + jobStatus); Console.WriteLine(" Rows/Bytes Synced:" + apiResponse.rowsSynced + "/" + apiResponse.bytesSynced); Console.WriteLine(" Sync Start Time:" + apiResponse.startTime); Console.WriteLine(" Sync Last Updated:" + apiResponse.lastUpdatedAt); Console.WriteLine(" Sync Duration:" + apiResponse.duration); } } Please note that you need to replace {YourApiKey} with your actual API key and <your-public-ip> with your server's public IP address. This information is extracted from the [Airbyte tutorial on creating and monitoring a data pipeline using the Airbyte API](https://airbyte.com/tutorials/create-and-monitor-a-data-pipeline-using-the-airbyte-api).Nguyen Dao (Bach)
10/28/2023, 2:19 PMkapa.ai
10/28/2023, 2:19 PMkapa.ai
10/28/2023, 2:20 PMhttp://<your-public-ip>:8001/api/v1/jobs/{{jobId}} Replace <your-public-ip> with the actual public IP address of your server and {{jobId}} with the actual ID of the job you want to monitor. Here is a sample code snippet on how to use this endpoint: csharp //Checks every 10 seconds the status of the job while(jobStatus == "running") {{ //Gets status of the job client = new RestClient("http://<your-public-ip>:8001/api/v1/jobs/" + jobId);//We add the jobId request = new RestRequest(); request.AddHeader("accept", "application/json"); request.AddHeader("content-type", "application/json"); request.AddHeader("Authorization", "Bearer {{YourApiKey}}"); dynamic statusResponse = client.ExecuteGet(request); //Deserialize response to get the status of the job apiResponse = JsonConvert.DeserializeObject(statusResponse.Content); jobStatus = apiResponse.status; //Waits 10 seconds.. Thread.Sleep(10000); //Prints info in console depending on the status if (jobStatus == "running") {{ Console.WriteLine("Job running..."); }} else {{ Console.WriteLine("Job Finished..."); Console.WriteLine(" "); Console.WriteLine("Sync details:"); Console.WriteLine(" JobId:" + apiResponse.jobId); Console.WriteLine(" Status:" + jobStatus); Console.WriteLine(" Rows/Bytes Synced:" + apiResponse.rowsSynced + "/" + apiResponse.bytesSynced); Console.WriteLine(" Sync Start Time:" + apiResponse.startTime); Console.WriteLine(" Sync Last Updated:" + apiResponse.lastUpdatedAt); Console.WriteLine(" Sync Duration:" + apiResponse.duration); }} }} Please note that you need to replace {{YourApiKey}} with your actual API key and <your-public-ip> with your server's public IP address. This information is extracted from the [Airbyte tutorial on creating and monitoring a data pipeline using the Airbyte API](https://airbyte.com/tutorials/create-and-monitor-a-data-pipeline-using-the-airbyte-api).