Mahuta

马胡塔

Mahuta （以前称为 IPFS-Store）是一个库，用于聚合和整合应用程序在 IPFS 网络上存储的文件或文档。它提供了一个解决方案，以方便的方式收集、存储、索引、缓存和搜索系统处理的 IPFS 数据。

项目状况

服务	掌握	发展
CI状态
测试覆盖率
宾特雷
码头工人
声纳

特征

• 索引：Mahuta 将文档或文件存储在 IPFS 上，并使用可选元数据对哈希进行索引。
• 发现：可以使用复杂的逻辑查询或模糊/全文搜索来搜索索引的文档和文件）
• 可扩展：使用异步写入机制和缓存针对大规模应用程序进行了优化
• 复制：副本集可以配置为跨多个节点（标准 IPFS 节点或 IPFS 集群节点）复制（固定）内容
• 多平台：Mahuta 可以用作基于 JVM 的应用程序的简单嵌入式 Java 库，也可以作为简单、可扩展且可配置的 Rest API 运行。

---

入门

这些说明将为您提供在本地计算机上启动并运行的项目副本，以用于开发和测试目的。

先决条件

Mahuta 取决于两个组成部分：

• IPFS 节点（go 或 js 实现）
• 搜索引擎（目前仅支持ElasticSearch）

了解如何运行这两个组件 首先运行 IPFS 和 ElasticSearch

Java库

1. 导入 Maven 依赖项（核心模块 + 索引器）

< repository >
    < id >consensys-kauri</ id >
    < name >consensys-kauri</ name >
    < url >https://consensys.bintray.com/kauri/</ url >
</ repository >

< dependency >
    < groupId >net.consensys.mahuta</ groupId >
    < artifactId >mahuta-core</ artifactId >
    < version >${MAHUTA_VERSION}</ version >
</ dependency >
< dependency >
    < groupId >net.consensys.mahuta</ groupId >
    < artifactId >mahuta-indexing-elasticsearch</ artifactId >
    < version >${MAHUTA_VERSION}</ version >
</ dependency >

2. 配置 Mahuta 以连接到 IPFS 节点和索引器

 Mahuta mahuta = new MahutaFactory()
    .configureStorage(IPFSService.connect("localhost", 5001))
    .configureIndexer(ElasticSearchService.connect("localhost", 9300, "cluster-name"))
    .defaultImplementation();

3. 执行高级操作

 IndexingResponse response = mahuta.prepareStringIndexing("article", "## This is my first article")
    .contentType("text/markdown")
    .indexDocId("article-1")
    .indexFields(ImmutableMap.of("title", "First Article", "author", "greg"))
    .execute();
    
GetResponse response = mahuta.prepareGet()
    .indexName("article")
    .indexDocId("article-1")
    .loadFile(true)
    .execute();
    
SearchResponse response = mahuta.prepareSearch()
    .indexName("article")
    .query(Query.newQuery().equals("author", "greg"))
    .pageRequest(PageRequest.of(0, 20))
    .execute();

欲了解更多信息，Mahuta Java API

Spring数据

1. 导入 Maven 依赖项

 <dependency>
    <groupId>net.consensys.mahuta</groupId>
    <artifactId>mahuta-springdata</artifactId>
    <version>${MAHUTA_VERSION}</version>
</dependency>

2. 配置您的 spring 数据存储库

 @IPFSDocument(index = "article", indexConfiguration = "article_mapping.json", indexContent = true)
public class Article {
    
    @Id
    private String id;

    @Hash
    private String hash;

    @Fulltext
    private String title;

    @Fulltext
    private String content;

    @Indexfield
    private Date createdAt;

    @Indexfield
    private String createdBy;
}



public class ArticleRepository extends MahutaRepositoryImpl<Article, String> {

    public ArticleRepository(Mahuta mahuta) {
        super(mahuta);
    }
}

欲了解更多信息，Mahuta Spring Data

使用 Docker 的 HTTP API

先决条件

• 码头工人
• 使用 Docker 运行 IPFS 和 ElasticSearch

码头工人

 $ docker run -it --name mahuta  
    -p 8040:8040 
    -e MAHUTA_IPFS_HOST=ipfs 
    -e MAHUTA_ELASTICSEARCH_HOST=elasticsearch 
    gjeanmart/mahuta

Docker 组合

查看文档以使用 Docker 配置 Mahuta HTTP-API。

示例

要访问 API 文档，请转至 Mahuta HTTP API

创建索引article

• 样品请求：

 curl -X POST 
  http://localhost:8040/mahuta/config/index/article 
  -H 'Content-Type: application/json' 

• 成功响应：

  • 代码：200
    内容：

 {
    "status": "SUCCESS"
}

存储和索引文章及其元数据

• 样品请求：

 curl -X POST 
  'http://localhost:8040/mahuta/index' 
  -H 'content-type: application/json' 
  -d '{"content":"# Hello world,n this is my first file stored on **IPFS**","indexName":"article","indexDocId":"hello_world","contentType":"text/markdown","index_fields":{"title":"Hello world","author":"Gregoire Jeanmart","votes":10,"date_created":1518700549,"tags":["general"]}}'

• 成功响应：

  • 代码：200
    内容：

 {
  "indexName": "article",
  "indexDocId": "hello_world",
  "contentId": "QmWHR4e1JHMs2h7XtbDsS9r2oQkyuzVr5bHdkEMYiqfeNm",
  "contentType": "text/markdown",
  "content": null,
  "pinned": true,
  "indexFields": {
    "title": "Hello world",
    "author": "Gregoire Jeanmart",
    "votes": 10,
    "createAt": 1518700549,
    "tags": [
      "general"
    ]
  },
  "status": "SUCCESS"
}

按查询搜索

• 样品请求：

 curl -X POST 
 'http://localhost:8040/mahuta/query/search?index=article' 
 -H 'content-type: application/json' 
 -d '{"query":[{"name":"title","operation":"CONTAINS","value":"Hello"},{"name":"author.keyword","operation":"EQUALS","value":"Gregoire Jeanmart"},{"name":"votes","operation":"GT","value":"5"}]}'

• 成功响应：

  • 代码：200
    内容：

 {
  "status": "SUCCESS",
  "page": {
    "pageRequest": {
      "page": 0,
      "size": 20,
      "sort": null,
      "direction": "ASC"
    },
    "elements": [
      {
        "metadata": {
          "indexName": "article",
          "indexDocId": "hello_world",
          "contentId": "Qmd6VkHiLbLPncVQiewQe3SBP8rrG96HTkYkLbMzMe6tP2",
          "contentType": "text/markdown",
          "content": null,
          "pinned": true,
          "indexFields": {
            "author": "Gregoire Jeanmart",
            "votes": 10,
            "title": "Hello world",
            "createAt": 1518700549,
            "tags": [
              "general"
            ]
          }
        },
        "payload": null
      }
    ],
    "totalElements": 1,
    "totalPages": 1
  }
}