feat: init es reader and writer

.github/workflows/Build.yml

@@ -4,7 +4,7 @@ on:
   push:
     branches:
     - main
-    - v0.2.x
+    - v0.2.x-es
   pull_request:
     branches:
     - main

README.md

@@ -35,6 +35,8 @@ This data synchronization tool has the synchronization capability for the follow
 |              | Sqlite3            | √            | √          | [Read](datax/plugin/reader/sqlite3/README.md)、[Write](datax/plugin/writer/sqlite3/README.md) |
 | Unstructured Data Stream    | CSV                | √            | √          | [Read](datax/plugin/reader/csv/README.md)、[Write](datax/plugin/writer/csv/README.md) |
 |              | XLSX（excel）      | √            | √          | [Read](datax/plugin/reader/xlsx/README.md)、[Write](datax/plugin/writer/xlsx/README.md) |
+|              | Elasticsearch      | √            | √          | [Read](datax/plugin/reader/elasticsearch/README.md)、[Write](datax/plugin/writer/elasticsearch/README.md) |
+
 
 ### Getting Started
 

datax/plugin/reader/elasticsearch/README.md

@@ -0,0 +1 @@
+# ElasticsearchReader Plugin Documentation

datax/plugin/reader/elasticsearch/job.go

@@ -0,0 +1 @@
+package elasticsearch

datax/plugin/reader/elasticsearch/reader.go

@@ -0,0 +1,31 @@
+package elasticsearch
+import (
+	"github.com/Breeze0806/go-etl/config"
+	spireader "github.com/Breeze0806/go-etl/datax/common/spi/reader"
+)
+
+//A reader is uesed to extract data from data source 
+type Reader struct {
+	pluginConf *config.JSON
+}
+
+//ResourcesConfig returns the configuration of the data source to initiate the reader.
+func (r *Reader) ResourcesConfig() *config.JSON {
+	return r.pluginConf
+}
+
+//Job returns a description of how the reader extracts data from the data source.
+func (r *Reader) Job() spireader.Job {
+	// todo like below
+	//job := NewJob()
+	//job.SetPluginConf(r.pluginConf)
+	//return job
+}
+
+//Task returns the smallest execution unit obtained by maximizing the split of a Job
+func (r *Reader) Task() spireader.Task {
+	// todo like below
+	//task := fNewTask()
+	//task.SetPluginConf(r.pluginConf)
+	//return task
+}

datax/plugin/reader/elasticsearch/resources/plugin.json

@@ -0,0 +1,5 @@
+{
+	"name" : "elasticsearchreader",
+	"developer":"",
+	"description":""
+}

datax/plugin/reader/elasticsearch/resources/plugin_job_template.json

@@ -0,0 +1,6 @@
+{
+	"name": "elasticsearchreader",
+	"parameter": {
+
+	}
+}

datax/plugin/reader/elasticsearch/task.go

@@ -0,0 +1 @@
+package elasticsearch

datax/plugin/writer/elasticsearch/README.md

@@ -0,0 +1 @@
+# ElasticsearchWriter Plugin Documentation

datax/plugin/writer/elasticsearch/job.go

@@ -0,0 +1 @@
+package elasticsearch

datax/plugin/writer/elasticsearch/resources/plugin.json

@@ -0,0 +1,5 @@
+{
+	"name" : "elasticsearchwriter",
+	"developer":"",
+	"description":""
+}

datax/plugin/writer/elasticsearch/resources/plugin_job_template.json

@@ -0,0 +1,6 @@
+{
+	"name": "elasticsearchwriter",
+	"parameter": {
+
+	}
+}

datax/plugin/writer/elasticsearch/task.go

@@ -0,0 +1 @@
+package elasticsearch

datax/plugin/writer/elasticsearch/writer.go

@@ -0,0 +1,33 @@
+package elasticsearch
+
+import (
+	"github.com/Breeze0806/go-etl/config"
+	spiwriter "github.com/Breeze0806/go-etl/datax/common/spi/writer"
+)
+
+
+//A writer is uesed to load data into data source 
+type Writer struct {
+	pluginConf *config.JSON
+}
+
+//ResourcesConfig returns the configuration of the data source to initiate the writer.
+func (w *Writer) ResourcesConfig() *config.JSON {
+	return w.pluginConf
+}
+
+//Job returns a description of how the reader extracts data from the data source.
+func (w *Writer) Job() spiwriter.Job {
+	// todo like below
+	//job := NewJob()
+	//job.SetPluginConf(w.pluginConf)
+	//return job
+}
+
+//Task returns the smallest execution unit obtained by maximizing the split of a Job
+func (w *Writer) Task() spiwriter.Task {
+    // todo like below
+	//task := NewTask()
+	//task.SetPluginConf(w.pluginConf)
+	//return task
+}