在入图功能模块中，你可以将不同来源的数据导入至嬴图数据库，支持的数据源包括CSV、JSON、JSONL、PostgreSQL、SQL Server、MySQL、BigQuery、Neo4j以及Kafaka。

Loader和Task

每个Loader（载入程序）包含一个或多个导入Task（任务）。一个Loader里的Task可以单独执行，也可以同时执行（串行或并行）。

创建Loader

在入图主页点击New Loader按钮创建新Loader，默认名称为My Loader。

点击Loader进入配置页后，可修改Loader的名称和描述。

创建Task

在Loader配置页中点击New Task按钮可以创建新Task，创建每个Task时需选择数据源。每个Loader中可添加多个Task。

添加Task后，你可以在左侧的Task卡片上修改每个Task的名称。点击每个Task后，在右侧配置这个Task的详细信息，具体请参考附录：Task配置。

导入

导入单个Task

点击每个Task配置页的Import按钮可单独执行该Task的导入任务。

运行Loader

点击左侧Task列表顶部的Run按钮可批量执行该Loader中所有Task的导入任务。

关于所有Task的执行顺序：

• 自上而下执行Task，支持拖拽修改Task卡片顺序。
• 点击Task卡片右上角的S（串行）或P（并行）标签，指定该Task是单独执行（S）还是和别的Task一起执行（P）。
• 相邻的P Task，连同这一组Task之前的S Task会并行执行。

同时导入点和边时可能会出现错误，因为边的创建要求其两个端点必须在图集中已存在。因此，考虑在导入边之前导入点，或者正确地配置好Create Node If Not Exist项目以及Insert/Upsert/Overwrite这几种插入方式。

导入日志

执行导入时，用户可以在Task卡片中看到进度条。导入结束后，嬴图Manager会提供相应的导入日志，说明导入是否全部成功。用户可在每个Task中下载相应的导入日志和未成功导入的数据。

导入/导出Loader

用户可以将Loader导出为ZIP文件，并在需要时重新导入至嬴图Manager。

附录：Task配置

Settings

每种数据源的Task配置有所不同，但Settings这部分的设置都是一样的。

任何新的图集、Schema或属性旁会出现一个警告图标，它们会在导入过程中被自动创建。

CSV

File

以下示例CSV文件用于导入@账户点，它的表头写明了属性名和数据类型：

_id:_id,username:string,brithYear:int32
U001,risotto4cato,1978
U002,jibber-jabber,1989
U003,LondonEYE,1982

以下示例CSV文件用于导入@关注边，它没有表头：

103,risotto4cato,jibber-jabber,1634962465
102,LondonEYE,jibber-jabber,1634962587

Mapping

上传或选择文件后，此部分才可见：

JSON, JSONL

File

以下示例JSON文件用于导入@用户点：

[{
	"_uuid": 1,
	"_id": "U001",
	"level": 2,
	"registeredOn": "2018-12-1 10:20:23",
	"tag": null
}, {
	"_uuid": 2,
	"_id": "U002",
	"level": 3,
	"registeredOn": "2018-12-1 12:45:12",
	"tag": "cloud"
}]

以下示例JSONL文件用于导入@用户点：

{"_uuid": 1, "_id": "U001", "level": 2, "registeredOn": "2018-12-1 10:20:23", "tag": null}
{"_uuid": 2, "_id": "U002", "level": 3, "registeredOn": "2018-12-1 12:45:12", "tag": "cloud"
}

Mapping

上传或选择文件后，此部分才可见：

PostgreSQL, SQL Server, MySQL

Source Database

SQL

书写SQL查询语句从数据库获取数据，然后点击Preview将结果映射为点或边的属性。

以下示例SQL返回users表里的name和registeredOn这两列数据：

SELECT name, registeredOn FROM users;

Mapping

SQL返回结果后，此部分可见：

BigQuery

Source Database

SQL

书写SQL查询语句从BigQuery获取数据，然后点击Preview将结果映射为点或边的属性。

以下示例SQL返回users表里的全部列数据：

SELECT * FROM users;

Mapping

SQL返回结果后，此部分可见：

Neo4j

Neo4j

Cypher

书写Cypher查询语句从Neo4j获取数据，然后点击Preview将结果映射为点或边的属性。

以下示例Cypher返回所有标签为user的点：

MATCH (n:user)

Mapping

Cypher返回结果后，此部分可见：

Kafka

Kafka

Mapping

接收到消息结果后，此部分可见：

Kafka的Task（消费者）开始后会一直保持运行来接收新发布的消息，需要时请手动停止。