semvec/pypi-packages huggingface dataset:
solrdataimport 1.0.2
Data import from cassandra to solr
License: Apache 2.0

Data import from cassandra to Solr
=========================================


debug
------------------------

if __name__ == '__main__':
    import logging.config
    logging.basicConfig(level=logging.ERROR,
                        format='%(levelname)-s: %(message)s')

    
    setting = {
        "fullDataImport": False,
        "config_file": "/fil_epath/test.json",
        "solr_url": "http://ip:8983/solr/",
        "solr_cluster": True or False,
        "cassandra": {
            "hosts": ["ip"],
            "username": "username",
            "password": "password"
        }
    }
    dataimport = DataImport(setting)
    # dataimport.exportSolr('userinfo', **{"userId": "27aa99c7-3673-4602-95a9-ce0620b51695"})
    # dataimport.deleteSolr('game_info', **{"game_id": "30ae2131-87d4-4f3c-802d-b671ddeb6648"})


config
----------------------

```
[{
    "name": "userinfo",
    "table": "userinfo",
    "key": ["userId"],
    "nest": [{
        "table": "sso.member",
        "nestKey": {
            "member_id": "userId"
        },
        "cache": true
    }],
    "exclude": ["member_id"],
    "solrId": ["member_id"]
},{
    "name": "hb.game_epic",
    "core_name": "userinfo",
    "table": "hb.game_epic",
    "key": ["epic_id"],
    "nest": [{
        "table": "hb.epic_member_map",
        "nestKey": {
            "epic_id": "epic_id"
        },
        "condition": {
            "team_id": "b39ba1e9-4505-49ce-92d7-92c4b77d9923"
        },
        "alias": {
            "epic_id": "team_epic_id"
        }
    }],
    "solrId": ["epic_id", "member_id"]，
    "solrKey": [epic_id", "member_id", "xid", "xkey"] # Option
}]
```